Kafka Stream - агрегирование данных из нескольких экземпляров локальных таблиц KTable - PullRequest
0 голосов
/ 10 октября 2019

У меня есть несколько экземпляров MyApp, которые прослушивают другой раздел с помощью KTables локального хранилища состояний. Я знаю, что мы можем использовать RPC для запроса удаленного хранилища кэша Ссылка .

Но проблема в том, что я не хочу использовать конечные точки REST, я хочу иметь SSE (Server-Sent)Событие) слой поверх MyApp, который должен прослушивать изменения в локальном хранилище состояний KTables и публиковать события. Есть ли способ, которым я могу достичь этого?

...