[
https://issues.apache.org/jira/browse/KAFKA-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4002.
------------------------------------------
Resolution: Fixed
Fix Version/s: (was: 0.11.0.0)
0.10.1.0
Issue resolved by pull request 1686
[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)
