Github user srdo commented on the issue:
https://github.com/apache/storm/pull/2156
@WolfeeTJ We are dropping support for NamedSubscription and
PatternSubscription in 2.0.0 and deprecating them in 1.2.0 because Kafka's
mechanism for automatically assigning partitions to consumers is a bad fit for
Storm. See https://issues.apache.org/jira/browse/STORM-2542 for details.
From 1.2.0 (1.x-branch) on, the spout will assign partitions using the
https://github.com/apache/storm/blob/master/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/ManualPartitionSubscription.java
class. The default subscription in KafkaSpoutConfig will also change to use
this subscription.
Partition assignment happens in refreshPartitions for the
ManualPartitionSubscription, and poll won't trigger rebalance anymore, so we
shouldn't need to worry about partitions changing when we call poll.
---
