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