Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Prose adding one new property to the Kafka Connect worker.properties file, which requires changing WorkerConfig.java

Name: uniquetask.client.idids
Doc: If true the set to TASK the task id is appended to the client.id used by each Source or Sink task. This avoids name conflicts on JMX mbeans and enables task-level client metrics.
Type: BOOLEANenum:  DEFAULT | TASK
Default: falseDEFAULT

Proposed Changes

Add a worker configuration option to automatically append task ID to the client ID used by producer or consumer instances instantiated by a Worker. This ensures all JMX MBean names used within a Kafka Connect cluster are distinct.

...