Github user WolfeeTJ commented on the issue:
https://github.com/apache/storm/pull/2156
Hi @srdo , I happened to see errors like this in my production after
applied your PR:
```
2017-09-06 13:12:01.707 o.a.s.util Thread-15-spout-executor[103 103]
[ERROR] Async loop died!
java.lang.IllegalStateException: No current assignment for partition
kafka_bd_trigger_action-22
at
org.apache.kafka.clients.consumer.internals.SubscriptionState.assignedState(SubscriptionState.java:231)
~[stormjar.jar:?]
at
org.apache.kafka.clients.consumer.internals.SubscriptionState.resume(SubscriptionState.java:350)
~[stormjar.jar:?]
at
org.apache.kafka.clients.consumer.KafkaConsumer.resume(KafkaConsumer.java:1332)
~[stormjar.jar:?]
at
org.apache.storm.kafka.spout.KafkaSpout.pollKafkaBroker(KafkaSpout.java:323)
~[stormjar.jar:?]
at
org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:234)
~[stormjar.jar:?]
at
org.apache.storm.daemon.executor$fn__9708$fn__9723$fn__9754.invoke(executor.clj:646)
~[storm-core-1.1.1-SNAPSHOT.jar:1.1.1-SNAPSHOT]
at org.apache.storm.util$async_loop$fn__553.invoke(util.clj:484)
[storm-core-1.1.1-SNAPSHOT.jar:1.1.1-SNAPSHOT]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]
2017-09-06 13:12:01.709 o.a.s.d.executor Thread-15-spout-executor[103 103]
[ERROR]
java.lang.IllegalStateException: No current assignment for partition
kafka_bd_trigger_action-22
at
org.apache.kafka.clients.consumer.internals.SubscriptionState.assignedState(SubscriptionState.java:231)
~[stormjar.jar:?]
at
org.apache.kafka.clients.consumer.internals.SubscriptionState.resume(SubscriptionState.java:350)
~[stormjar.jar:?]
at
org.apache.kafka.clients.consumer.KafkaConsumer.resume(KafkaConsumer.java:1332)
~[stormjar.jar:?]
at
org.apache.storm.kafka.spout.KafkaSpout.pollKafkaBroker(KafkaSpout.java:323)
~[stormjar.jar:?]
```
I think the issue might happen because it could be possible partition
reassignment takes effect at kafkaConsumer.poll(), and as a result the
pausedPartitions is different from the actual assignment. How do you think?
---
