Есть ли способ отправлять сообщения напрямую из KTable в websocket в Kafka?
У меня есть данные, которые постоянно обновляются. Я держу их в Кафке, сжатые топи c. Когда приходит новый клиент веб-сокета, я хотел бы отправить ему текущее состояние моих данных, а затем я хочу отправлять ему автоматически при каждом изменении данных. Я считаю, что лучшим способом было бы как-то связать KTable (или GlobalKTable, или, возможно, какой-нибудь государственный магазин) с websocket. Возможно ли что-то подобное?