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

Reply via email to