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

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

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.0.0
    • Fix Version/s: 0.10.1.0
    • Component/s: KafkaConnect
    • Labels:
      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

          Issue Links

            Activity

              People

              • Assignee:
                liquanpei Liquan Pei
                Reporter:
                liquanpei Liquan Pei
                Reviewer:
                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