Greg Harris created KAFKA-15826:
-----------------------------------
Summary: WorkerSinkTask leaks Consumer if plugin start or stop
blocks indefinitely
Key: KAFKA-15826
URL: https://issues.apache.org/jira/browse/KAFKA-15826
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 3.6.0
Reporter: Greg Harris
Assignee: Greg Harris
The WorkerSourceTask cancel() method closes the Producer, releasing it's
resources. The WorkerSInkTask does not do the same for the Consumer, as it does
not override the cancel() method.
WorkerSinkTask should close the consumer if the task is cancelled, as progress
for a cancelled task will be discarded anyway.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
