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