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

Wed, 16 Oct 2024 03:30:17 -0700 

ignat233 created KAFKA-17808:
--------------------------------

             Summary: InstanceAlreadyExistsException: 
kafka.admin.client:type=app-info,id=connector-dlq-adminclient- when add 
connector with tasks
                 Key: KAFKA-17808
                 URL: https://issues.apache.org/jira/browse/KAFKA-17808
             Project: Kafka
          Issue Type: Bug
          Components: admin, config, core
            Reporter: ignat233
         Attachments: image-2024-10-16-13-00-36-667.png

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.
!image-2024-10-16-13-00-36-667.png! 
 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.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to