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

WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

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

            Dates

              Created:
              Updated:

              Slack

                Issue deployment