[ 
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Robert Metzger updated FLINK-3386:
----------------------------------
    Summary: Kafka consumers are not properly respecting the 
"auto.offset.reset" behavior  (was: Kafka consumers should not necessarily fail 
on expiring data)

> Kafka consumers are not properly respecting the "auto.offset.reset" behavior
> ----------------------------------------------------------------------------
>
>                 Key: FLINK-3386
>                 URL: https://issues.apache.org/jira/browse/FLINK-3386
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kafka Connector, Streaming Connectors
>    Affects Versions: 1.0.0
>            Reporter: Gyula Fora
>            Assignee: Robert Metzger
>
> 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)

Reply via email to