GitHub user kaustubhpriye opened a pull request:
https://github.com/apache/storm/pull/1268
fallbacks to startoffset time if offset is out of range
If the offset of kafka is purged / removed due to retention policy etc. The
user starts getting UpdateOffsetException, The current issue is, that there is
no way in 0.9.3 release to have a way in which we can enable storm to read from
starting of stream in case offset is missing.
There is a param "useStartOffsetTimeIfOffsetOutOfRange" which speak of it
is not used to effect.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kaustubhpriye/storm
honouring_useStartOffsetTimeIfOffsetOutOfRange
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1268.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 #1268
----
commit 63cb0419865498bf65b65f3ca148d481aa5cb313
Author: Kaustubh Priye <[email protected]>
Date: 2016-03-27T09:44:26Z
fallbacks to startoffset time if offset is out of range
----
---
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.
---
