(каждое событие содержит следующую информацию:
1. GUID события - String
2. Имя процесса, к которому относится данное событие - String
3. Номер экземпляра процесса - Long
4. Тип события (возможные значения: start, end и error) - String enum
5. Дата с временем события - Datetime
Нужно вычислять следующие агрегаты (в действительности их больше):
1. кол-во обработанных и ошибочных (если есть тип события error) сообщений;
2. среднее и максимальное время выполнения процесса;
Насколько понимаю это можно реализовать на Kafka Streams (ведь так?).
Если да, то есть ли какой-либо готовый или полуготовый инструмент для построения графиков (dashboard), т.е. визуализации данных в KTable?
Может лучше KSQL и некоторое BI-средство?
Единственный BI тул который поддерживает ksql нативно это Arcadia data
Обсуждают сегодня