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

Posted to commits@samza.apache.org by "Jagadish (JIRA)" <ji...@apache.org> on 2018/04/03 23:15:00 UTC

[jira] [Created] (SAMZA-1634) Update javadocs for SystemConsumer implementors

Jagadish created SAMZA-1634:
-------------------------------

             Summary: Update javadocs for SystemConsumer implementors
                 Key: SAMZA-1634
                 URL: https://issues.apache.org/jira/browse/SAMZA-1634
             Project: Samza
          Issue Type: Bug
            Reporter: Jagadish


Should update javadocs so that we are clear in our message to those who implement SystemConsumers:

In general, SystemConsumer instances are shared across all tasks and there's one instance of SystemConsumer created per-"system". While we guarantee that there will be no concurrent commits for the same task instance, no such guarantees are made across task instances.

It's expected for SystemConsumer implementations to be thread-safe and safely handle the following scenarios :
* poll on a task invoked concurrently with a commit on another task
* commits on different tasks invoked concurrently




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)