Github user mooso commented on the pull request: https://github.com/apache/storm/pull/651#issuecomment-140865013 (Not a project maintainer, just someone who ran into the same problem) I support the idea and encountered the same need myself, but I think they way it's implemented in this pull request isn't correct since it doesn't work for people who implement their own IEventDataScheme class. The way I did it was to change the signature of deserialize() in that interface to add a MessageId parameter, that way implementors of that class can choose to add the partition ID (and sequence number) properly if they wish. Would that work?
--- 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. ---