Thanks Senthil. This is helpful but I am worried about doing it with standalone process as our data is huge.
Is there a way to do the same thing using kstream and utilize cluster resources instead of doing with standalone client process ? Sent from my iPhone > On Apr 11, 2020, at 7:27 PM, SenthilKumar K <senthilec...@gmail.com> wrote: > > Hi, We can re-consume the data from particular point using consumer.seek() > and consumer.assign() API [1]. Pls check out documentation. > > If you have used timestamp at the time producing records , You can use > particular timestamp to consume records [2]. > > > https://kafka.apache.org/24/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html > https://mapr.com/docs/61/MapR_Streams/example-TimeBasedConsumer.html > > --Senthil >> On Sat, 11 Apr 2020, 6:24 pm KhajaAsmath Mohammed, <mdkhajaasm...@gmail.com> >> wrote: >> >> Hi, >> >> We have lost some data while processing and would like to reprocess it. >> May I know the procedure to do it . I have offsets numbers that I need to >> process. >> >> Any suggestions please. Would be really helpful. >> >> Thanks, >> Asmath >> >> Sent from my iPhone
