[ 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)