Deepthi Sridharan created SAMZA-2016:
----------------------------------------
Summary: Support config to specify where to start consuming from
when checkpoint is at a TTL-ed offset
Key: SAMZA-2016
URL: https://issues.apache.org/jira/browse/SAMZA-2016
Project: Samza
Issue Type: Improvement
Reporter: Deepthi Sridharan
Samza doesn't natively support specifying actions for consumers who might be
lagging behind on a stream and end up trying to consume an offset that is no
longer available in the stream (invalid or out of range offset rather than no
checkpoint state).
Since an out of range offset is a concept that is applicable to all streams, it
would be nice to have this configurable natively just like the native support
for `samza.offset.default` for a non existing checkpoint to save individual
systems from having to configs for them.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
