GitHub user prokopowicz opened a pull request:
https://github.com/apache/storm/pull/758
advance kafka offset when deserializer yields no object
also removes some tab-indenting in the surrounding code.
When a custom scheme returns an empty list of object-lists to the partition
manager, it should be handled the same as null. Otherwise, the partition
reader will be stuck at that offset.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/prokopowicz/storm master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/758.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #758
----
commit 5d499854bf4b236b2d5fc7078d7fc5343d89dbeb
Author: Pete Prokopowicz <[email protected]>
Date: 2015-09-23T15:09:23Z
advance kafka offset when deserializer yields no object
----
---
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.
---
