[jira] [Created] (KAFKA-4002) task.open() should be invoked in case that 0 partitions is assigned to task.

["Liquan Pei (JIRA)" <ji...@apache.org>]

Liquan Pei created KAFKA-4002:
---------------------------------

             Summary: task.open() should be invoked in case that 0 partitions is assigned to task. 
                 Key: KAFKA-4002
                 URL: https://issues.apache.org/jira/browse/KAFKA-4002
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 0.10.0.0
            Reporter: Liquan Pei
            Assignee: Liquan Pei
             Fix For: 0.11.0.0


 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 .



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)