samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Boris Shkolnik <>
Subject [DISCUSS] Offset checkpoint notification to the System Consumer
Date Tue, 25 Oct 2016 16:37:20 GMT
Currently we keep track of the progress of each consumer using
checkpointing mechanism. These checkpoints are controlled by Samza, and the
system consumer is not aware of it.
But some systems may require knowledge of the current checkpointed position
in the stream.
For this purpose we propose an optional notification mechanism for input
See the doc attached to SAMZA-1042 for details.

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message