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/26 18:14:20 UTC

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

     [ https://issues.apache.org/jira/browse/SAMZA-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Xinyu Liu updated SAMZA-981:
----------------------------
    Summary: Set consistent Kafka clientId for a job instance  (was: Set Kafka clientId consistent for a job instance)

> Set consistent Kafka clientId 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)