Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-2541

Manual partition assignment doesn't work

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.0.0, 1.1.0, 1.1.1
    • Fix Version/s: 2.0.0, 1.2.0, 1.1.2
    • Component/s: storm-kafka-client
    • Labels:
      None

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Srdo Stig Rohde Døssing
                Reporter:
                Srdo Stig Rohde Døssing
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 4.5h
                  4.5h