[jira] [Updated] (STORM-2541) Manual partition assignment doesn't work

["Stig Rohde Døssing (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/STORM-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stig Rohde Døssing updated STORM-2541:
--------------------------------------
    Fix Version/s: 1.1.2

> Manual partition assignment doesn't work
> ----------------------------------------
>
>                 Key: STORM-2541
>                 URL: https://issues.apache.org/jira/browse/STORM-2541
>             Project: Apache Storm
>          Issue Type: Bug
>          Components: storm-kafka-client
>    Affects Versions: 2.0.0, 1.1.0, 1.1.1
>            Reporter: Stig Rohde Døssing
>            Assignee: Stig Rohde Døssing
>             Fix For: 2.0.0, 1.2.0, 1.1.2
>
>          Time Spent: 4.5h
>  Remaining Estimate: 0h
>
> The manual partition assignment logic in ManualPartitionNamed/PatternSubscription is broken. The spout is unable to start. The subscription needs to call onPartitionsAssigned even if the current assignment is null, otherwise it becomes impossible to initialize the spout. The order of KafkaConsumer.assign and the calls to onPartitionsAssigned/Revoked is also wrong. The assignment must happen first, otherwise onPartitionsAssigned will get an IllegalStateException when it tries to call KafkaConsumer.seek on a partition the consumer is not yet assigned.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)