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)