You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Greg Harris (Jira)" <ji...@apache.org> on 2023/11/14 18:42:00 UTC

[jira] [Created] (KAFKA-15826) WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely

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)