[
https://issues.apache.org/jira/browse/KAFKA-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410819#comment-15410819
]
ASF GitHub Bot commented on KAFKA-4002:
---------------------------------------
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/1686
> 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.10.1.0
>
> Original Estimate: 4h
> Remaining Estimate: 4h
>
> 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)
