У меня есть тема Zeromq, которая генерирует сообщения каждую секунду.
Пример: {Orderno : 123 , Status : open} , {Orderno : 123 , Status : pending} ,{Orderno : 321 , Status : closed}
Я хочу записать обзор изменений состояния в сообщениях следующим образом.Я читал, что с Kafka мы можем достичь этого с помощью Ktable.Но для этого мне нужно отправить сообщения из очереди zeromq в другую тему Kafka и обработать изменения состояния.Это эффективное решение или написать скрипт / программу, которая проверяет orderno из потока сообщений из ZeroMQ и постоянно обновляет запись в таблице sql / nosql вместо использования kafka?