[
https://issues.apache.org/jira/browse/KAFKA-1332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15115030#comment-15115030
]
Robert Metzger commented on KAFKA-1332:
---------------------------------------
A Flink user recently requested support for handling situations where Flink's
KafkaConsumer can not keep up with the data volume (it starts lagging behind).
Ideally, we want users to decide themselves how to handle the situation (by
setting a custom new offset for the next {{poll()}} call). For our 0.8
connector, we can use {{offsetsBeforeTime()} call, for the 0.9 connector, there
is no API yet.
We are probably not going to address the issue immediately, but it would be
nice to properly expose this for Kafka 0.9 as well.
> Add functionality to the offsetsBeforeTime() API
> ------------------------------------------------
>
> Key: KAFKA-1332
> URL: https://issues.apache.org/jira/browse/KAFKA-1332
> Project: Kafka
> Issue Type: Sub-task
> Components: consumer
> Affects Versions: 0.10.0.0
> Reporter: Neha Narkhede
> Fix For: 0.10.0.0
>
>
> Add functionality to the offsetsBeforeTime() API to load offsets
> corresponding to a particular timestamp, including earliest and latest offsets
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
