Re: Flink-Kafka connector - partition offsets for a given timestamp?

2017-12-12 Thread Yang, Connie
release yet. We can try to make sure this happens for Flink 1.5, for which the proposed release date is around February 2018. Cheers, Gordon On Tue, Dec 12, 2017 at 3:53 AM, Yang, Connie <cy...@ebay.com<mailto:cy...@ebay.com>> wrote: Hi, Does Flink-Kafka connector allow job

Flink-Kafka connector - partition offsets for a given timestamp?

2017-12-11 Thread Yang, Connie
Hi, Does Flink-Kafka connector allow job graph to consume topoics/partitions from a specific timestamp? https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java#L469 seems to