[KAFKA-17808] InstanceAlreadyExistsException: kafka.admin.client:type=app-info,id=connector-dlq-adminclient- when add connector with tasks

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: connect
• Assignee: ignat233
• Reporter: ignat233
• Created: 16/Oct/24 12:28
• Updated: 18/Oct/24 18:10

Description

Why do we always create an admin client with the same "connector-dlq-adminclient-" value id?
https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L1008
For all other cases, a postfix is ​​added.

 I get "Error registering AppInfo mbean
javax.management.InstanceAlreadyExistsException: kafka.admin.client:type=app-info,id=connector-dlq-adminclient-." error for all tasks.
It looks like the ConnectorTaskId should be added.

Issue Links

• relates to: KAFKA-5295 Allow Kafka Connect source connectors to specify topic-specific settings for new topics
• links to: GitHub Pull Request #17538