[ https://issues.apache.org/jira/browse/STORM-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hugo Louro reassigned STORM-2541: --------------------------------- Assignee: Hugo Louro (was: Stig Rohde Døssing) > 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 > Reporter: Stig Rohde Døssing > Assignee: Hugo Louro > Time Spent: 3h > 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)