You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Boris Shkolnik (JIRA)" <ji...@apache.org> on 2016/10/24 17:57:58 UTC

[jira] [Created] (SAMZA-1042) [DISCUSS] Allow offset notifications for input systems

Boris Shkolnik created SAMZA-1042:
-------------------------------------

             Summary: [DISCUSS] Allow offset notifications for input systems
                 Key: SAMZA-1042
                 URL: https://issues.apache.org/jira/browse/SAMZA-1042
             Project: Samza
          Issue Type: Bug
            Reporter: Boris Shkolnik
            Assignee: Boris Shkolnik


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 systems.
See the attached doc for details.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)