Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Minor changes to accurately denote that the tasks don't create the producers and consumers.

...

PR Available here: https://github.com/apache/kafka/pull/6097


For consumers Consumers created by for sink tasks , the will have a default client.id will become of the form:


 connector-consumer-{connectorId}-{taskId}

   e.g. For connector "conn1", task "2" the default client ID would become: connector-consumer-conn1-2
For producers create by
Producers created for source tasks , the will have a default client.id will become of the form:

  connector-producer-{connectorId}-{taskId}
For dead
Dead-letter queue producers created by for sink tasks , the will have a default client.id will become of the form:

  connector-dlq-producer-{connectorId}-{taskId}

...