Github user hmcl commented on the issue:

    https://github.com/apache/storm/pull/2454
  
    @srdo Can you explain how can the drawback scenario you describe in your 
[comment](https://github.com/apache/storm/pull/2454#issuecomment-351428500) 
happen? When activate happens, refresh partitions will be called, 
onPartitionsRevoked will commit only for the partitions that are now assigned 
to the consumer (so acks that make commits eligible for other partitions won't 
matter), and onPartitionsReassigned will remove the offset managers for the 
partitions that are no longer assigned to this spout instance.


---

Reply via email to