Всем доброго дня! нубский вопрос есть по Kafka, пока не

Question

Всем доброго дня! нубский вопрос есть по Kafka, пока не

очень понял, что нужно что бы сделать такое:

вот есть у нас топик, в него кидаются данными, с десяток раз в минуту - скажем это записи, в каждой есть пара ключ-значение... хотелось бы строить простейшие агрегаты по этому потоку - видеть самое последнее значение по всем ключевым словам. Зачем? что бы потребители забирали данные когда им надо, а не по событию (так надо, специфика)
понятно что это пишется в Kafka Table. А кто это делает? сама Kafka? или некий код на Java внутри Kafka? или самому - забирать поток да агрегировать его где угодно и чем угодно, сохраняя snapshot или же меняя значения пар ключ-значение?

как-то не сложилось целостного понимания - кто делает агрегирование и запись в kafka table...

#kafka #russian #software

0

10.10.2018

1 ответов

13 просмотров

Oleg · Accepted Answer

Oleg

Kafka streams пишет в стор (например, роксдб), просто как либа подключается. Из этого стора можешь забирать key value

0

10.10.2018

52 похожих чатов

Всем доброго дня! нубский вопрос есть по Kafka, пока не

1 ответов

Похожие вопросы