#apache-kafka #apache-kafka-streams #confluent-platform #ksqldb
Вопрос:
Я работаю над проектом по фильтрации потоковой передачи данных с помощью ksqldb на основе номера учетной записи и ее работы. Но как измерить производительность ksqldb для фильтрации данных ?. Теперь моя схема для тестирования производительности основана на изменении переменных, которые влияют на потоковый процесс, например
- сумма номера счета
- количество ПОТОКОВ, создающих необработанные данные (данные нескольких производителей)
- объем данных на поток
- объем данных, отфильтрованных для очистки темы.
Производительность ksqldb определяется на основе разрыва временных меток первых и последних данных, которые отображаются в инструменте C3/kafka.
любые мысли приветствуются, спасибо