Greg Harris created KAFKA-15827:
-----------------------------------
Summary: KafkaBasedLog.withExistingClients leaks clients if start
is not called
Key: KAFKA-15827
URL: https://issues.apache.org/jira/browse/KAFKA-15827
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 3.6.0
Reporter: Greg Harris
Assignee: Greg Harris
The KafkaBasedLog base implementation creates consumers and producers, and
closes them after they are instantiated. There are subclasses of the
KafkaBasedLog which accept pre-created consumers and producers, and have the
responsibility for closing the clients when the KafkaBasedLog is stopped.
It appears that the KafkaBasedLog subclasses do not close the clients when
start() is skipped and stop() is called directly. This happens in a few tests,
and causes the passed-in clients to be leaked.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
