Re: Flink to get historical data from kafka between timespan t1 & t2

Posted by Aljoscha Krettek on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-to-get-historical-data-from-kafka-between-timespan-t1-t2-tp40479p40500.html

On 2021/01/08 16:55, [hidden email] wrote:
>Could you also attach the code snippet for KafkaSource`, `KafkaSourceBuilder`, and `OffsetInitializers` that you were referring to in your previous reply, for my reference please to make it more clearer for me.

Ah sorry, but this I was referring to the Flink code. You can start with
`KafkaSource` [1], which has an example block that shows how to use it
in the Javadocs.

[1]
https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java