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

Posted to commits@samza.apache.org by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2016/07/25 23:33:21 UTC

[jira] [Created] (SAMZA-981) Set Kafka clientId consistent for a job instance

Xinyu Liu created SAMZA-981:
-------------------------------

             Summary: Set Kafka clientId consistent for a job instance
                 Key: SAMZA-981
                 URL: https://issues.apache.org/jira/browse/SAMZA-981
             Project: Samza
          Issue Type: Improvement
    Affects Versions: 0.11
            Reporter: Xinyu Liu
            Assignee: Xinyu Liu


Remove the currentTimeMills and counter in the ClientId creation so the clientId will be the same for each job instance. With this change we can turn on kafka throttling on the job instance level.



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