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

Posted to dev@kafka.apache.org by "Greg Harris (Jira)" <ji...@apache.org> on 2022/12/05 18:34:00 UTC

[jira] [Created] (KAFKA-14443) Mirror Maker Connectors leak admin clients used for topic creation

Greg Harris created KAFKA-14443:
-----------------------------------

             Summary: Mirror Maker Connectors leak admin clients used for topic creation
                 Key: KAFKA-14443
                 URL: https://issues.apache.org/jira/browse/KAFKA-14443
             Project: Kafka
          Issue Type: Bug
          Components: mirrormaker
            Reporter: Greg Harris
            Assignee: Greg Harris


the MirrorMaker connectors are each responsible for creating internal topics.

For example, the Checkpoint connector creates a forwarding admin and passes it to a method to create the topic, but never closes the ForwardingAdmin or delegate objects: [https://github.com/apache/kafka/blob/13c9c78a1f4ad92023e8354069c6817b44c89ce6/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java#L161-L164]

Instead, this object should be intentionally closed when it is no longer needed, to prevent consuming resources in a running MM2 application.



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