I wonder how I can know I have processed all the messages in a partition?.
What I currently do is: 1. Publish a "ping" message with a "nonce", 2. read the partition (for the last know processed offset) replacing the application state every time I get a new state message in the topic, 3. when I get the "ping" message with the right "nonce", I know that the state I currently have is the last valid one and "process" it. 4. From now on, simply keep reading the topic waiting for new incoming changes.
Anything simpler? Thanks. -- Jesús Cea Avión _/_/ _/_/_/ _/_/_/ j...@jcea.es - https://www.jcea.es/ _/_/ _/_/ _/_/ _/_/ _/_/ Twitter: @jcea _/_/ _/_/ _/_/_/_/_/ jabber / xmpp:j...@jabber.org _/_/ _/_/ _/_/ _/_/ _/_/ "Things are not so easy" _/_/ _/_/ _/_/ _/_/ _/_/ _/_/ "My name is Dump, Core Dump" _/_/_/ _/_/_/ _/_/ _/_/ "El amor es poner tu felicidad en la felicidad de otro" - Leibniz
