[KAFKA-14443] Mirror Maker Connectors leak admin clients used for topic creation

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 3.4.0
• Component/s: mirrormaker
• Assignee: Greg Harris
• Reporter: Greg Harris
• Created: 05/Dec/22 18:33
• Updated: 08/Dec/22 03:02
• Resolved: 07/Dec/22 22:01

Description

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.

Issue Links

• is caused by: KAFKA-13401 Introduce a new Interface to manage Kafka resources in MM2
• links to: GitHub Pull Request #12955