You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "ignat233 (Jira)" <ji...@apache.org> on 2024/10/16 10:29:00 UTC

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

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)