Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-15826

WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • 3.6.0
    • None
    • connect
    • None

    Description

      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. 

      Attachments

        Issue Links

          Discovered while testing

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-15845 Add Junit5 test extension which detects leaked Kafka clients and servers

          • Major - Major loss of function.
          • In Progress
          links to

          Web Link GitHub Pull Request #14762

          Activity

            People

              Unassigned Unassigned
              gharris1727 Greg Harris
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: