Github user srdo commented on the issue: https://github.com/apache/storm/pull/1679 Thought about it a little more. The spout should probably just check when it polls messages that the messages are not behind the committedOffset. If they are, the committedOffset needs to move to the left. It's a little irritating that the consumer doesn't expose an API to let the client know that an unclean leader election happened. It would be nice if for example ConsumerRebalanceListener had a method to tell the client to roll back the committed offset to the new LEO after an unclean leader was elected.
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---