Github user WolfeeTJ commented on the issue:
https://github.com/apache/storm/pull/2156
Hi @srdo , I'm not sure, so please correct me if I were wrong:
So far as I could see, I'm using the default `NamedSubscription`. And I
checked the code, it's doing NOOP in
`org.apache.storm.kafka.spout.Subscription#refreshAssignment()`.
My understanding is, actual reassignment happens when using
`final ConsumerRecords<K, V> consumerRecords =
kafkaConsumer.poll(kafkaSpoutConfig.getPollTimeoutMs());`
in `org.apache.storm.kafka.spout.KafkaSpout#pollKafkaBroker()`.
So we might need to get the fresh partition assignment for
`kafkaConsumer.pause(pausedPartitions);` somehow after a
`kafkaConsumer.poll()`, because the previous `pollablePartitions` list might
has been changed after `kafkaConsumer.poll()` ?
---
