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
