Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-981

Set consistent Kafka clientId for a job instance

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.11.0
    • 0.11.0
    • None
    • None

    Description

      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.

      Attachments

        1. SAMZA-981.0.patch
          15 kB
          Xinyu Liu

        Activity

          People

            xinyu Xinyu Liu
            xinyu Xinyu Liu
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: