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

2021-01-13 Thread VINAY.RAICHUR
Ok. Attached is the PPT of what am attempting to achieve w.r.t. time Hope I am all set to achieve the three bullets mentioned in attached slide to create reports with KafkaSource and KafkaBuilder approach. If you have any additional tips to share please do so after going through the slide

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

2021-01-12 Thread VINAY.RAICHUR
Hi Aljoscha Not sure about your proposal regarding Point 3: * firstly how is it ensured that the stream is closed? If I understand the doc correctly the stream will be established starting with the latest timestamp (hmm... is it not a standard behaviour?) and will never finish

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

2021-01-12 Thread VINAY.RAICHUR
Hi Team & Aljoscha Any update on below please? -Original Message- From: RAICHUR, VINAY Sent: 11 January 2021 19:43 To: 'Aljoscha Krettek' ; user@flink.apache.org Subject: RE: Flink to get historical data from kafka between timespan t1 & t2 Importance: High Hi Aljoscha, Currently in our

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

2021-01-08 Thread VINAY.RAICHUR
Thanks Aljoscha for your prompt response. It means a lot to me  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. Kind regards,

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

2021-01-07 Thread VINAY.RAICHUR
Hi Flink Community Team, This is a desperate request for your help on below. I am new to the Flink and trying to use it with Kafka for Event-based data stream processing in my project. I am struggling using Flink to find solutions to my requirements of project below: 1. Get all Kafka