[
https://issues.apache.org/jira/browse/KAFKA-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-15826:
-----------------------------------
Assignee: (was: Greg Harris)
> 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
> 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)
