Hey,
I have samza job with a number of tasks, each of which holds some state
in its embedded store. I want to expose this store for reading to
outside world via some kind of RPC mechanism. What could be the best
solution for this?
The only solution which comes to my mind is to make my tasks, in
addition to normal processing, to consume request messages with some
correlation IDs on a special request topic, and to put response messages
with the same correlation IDs into special response topic. So it's like
RPC-over-Kafka solution which seems to me suboptimal.
Any thoughts are welcome!
--
Vladimir Lebedev
http://linkedin.com/in/vlebedev
