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 [email protected] or file a JIRA ticket
with INFRA.
---
