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

Set consistent Kafka clientId for a job instance

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.11.0
    • Fix Version/s: 0.11.0
    • Component/s: None
    • Labels:
      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

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

              Dates

              • Created:
                Updated:
                Resolved: