У меня есть события, приходящие в Кафку.Требуется прочитать входящие данные и получить счетчики по регионам для ежечасного окна.Я использую потоки Кафки для агрегирования данных, и ниже вывод.
[KTABLE-TOSTREAM-0000000007]: [59@1542934800000/1542938400000], 289
- 59 это region_id
- 1542934800000/1542938400000 - время начала и окончания окна
- 289 - это число
Я хочу опубликовать эти данные (region_id, count и время начала окна) в API.Каков наилучший способ сделать это?