[
https://issues.apache.org/jira/browse/KAFKA-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808804#comment-17808804
]
Greg Harris commented on KAFKA-15826:
-------------------------------------
The BlockingConnectorTest which was leaking the client in our tests was
remediated with [https://github.com/apache/kafka/pull/12290] .
The core flaw still exists, so I'm going to leave this ticket open.
> 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: connect
> Affects Versions: 3.6.0
> Reporter: Greg Harris
> Assignee: Greg Harris
> Priority: Minor
>
> 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)
