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

task.open() should be invoked in case that 0 partitions is assigned to task.

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.0.0
    • 0.10.1.0
    • KafkaConnect
    • None

    Description

      In case that 0 partitions is assigned to a task, the open() call in task was not invoked, but then put() was called later. The put() call with empty data is to hand control to the task so that it can continue working on the buffered data.

      If task.open() is not invoked in case of 0 partitions are assigned, connector developers needs to do some special handling in this case, i.e. do not call any method in writer to avoid null pointer exceptions. To make the connector developers' life easy, it probably better to change the behavior so the call is made even 0 partitions are assigned .

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            liquanpei Liquan Pei
            liquanpei Liquan Pei
            Ewen Cheslack-Postava Ewen Cheslack-Postava
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - 4h
                4h
                Remaining:
                Remaining Estimate - 4h
                4h
                Logged:
                Time Spent - Not Specified
                Not Specified

                Slack

                  Issue deployment