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

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

Stig Rohde Døssing created STORM-2541:
-----------------------------------------

             Summary: 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: Stig Rohde Døssing


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.3.15#6346)