Вам потребуется трехуровневое приложение.
Kafka - это ваш внутренний уровень для хранения данных.
Некоторый уровень API существует для выполнения RP C. Kafka Streams Интерактивные запросы могут быть использованы для создания KTable хранилища значений ключей для запросов типа get-by-id.
На вашем уровне API также может запускаться активный поток клиентов Kafka, который помещает сообщения в веб-сокет или как сообщения SSE. ,
Ваше веб-приложение откроется и подпишется на веб-сокет и будет использовать JS для обновления DOM.
Пользовательский ввод на сайте может отправить POST или GET обратно в API.
Слой API будет опрашивать или pu sh (другие) темы Кафки