You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/11 12:28:18 UTC

[jira] [Created] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

Gyula Fora created FLINK-3386:
---------------------------------

             Summary: Kafka consumers should not necessarily fail on expiring data
                 Key: FLINK-3386
                 URL: https://issues.apache.org/jira/browse/FLINK-3386
             Project: Flink
          Issue Type: Improvement
          Components: Streaming Connectors
    Affects Versions: 1.0.0
            Reporter: Gyula Fora


Currently if the data in a kafka topic expires while reading from it, it causes an unrecoverable failure as subsequent retries will also fail on invalid offsets.

While this might be the desired behaviour under some circumstances, it would probably be better in most cases to automatically jump to the earliest valid offset in these cases.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)