Github user srdo commented on the issue:
https://github.com/apache/storm/pull/2791
@wangzzu Hi, I'm not sure this should be happening. We're not using the
`KafkaConsumer.subscribe` API anymore, so Kafka shouldn't be managing the
partition assignment.
Can you confirm that you're using storm-kafka-client 1.2.0? Could you
please post your KafkaSpoutConfig? ---
