[GitHub] storm issue #2791: STORM-3176: KafkaSpout commit offset occurs CommitFailedE...

[wangzzu]

Github user wangzzu commented on the issue:

https://github.com/apache/storm/pull/2791
  
@srdo I found that we are using the deprecated Subscription subtypes 
actually, thx.


---

[GitHub] storm issue #2791: STORM-3176: KafkaSpout commit offset occurs CommitFailedE...

[srdo]

Github user srdo commented on the issue:

https://github.com/apache/storm/pull/2791
  
@wangzzu Yes, but it should also have been fixed in 1.1.2. Please make sure 
you're not using one of the deprecated Subscription subtypes, e.g. 
https://github.com/apache/storm/blob/v1.1.2/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/NamedSubscription.java


---

[GitHub] storm issue #2791: STORM-3176: KafkaSpout commit offset occurs CommitFailedE...

[wangzzu]

Github user wangzzu commented on the issue:

https://github.com/apache/storm/pull/2791
  
@srdo sorry, the version I used is 1.1.2. This problem has already fixed in 
1.2.0.


---

[GitHub] storm issue #2791: STORM-3176: KafkaSpout commit offset occurs CommitFailedE...

[srdo]

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? 


---