If cannot (or don't want to) modify your code, you can also stop the whole application and use `bin/kafka-consumer-groups.sh` to set a new start offset per partition. Afterward, you can just restart the application and it will pick up the corresponding start offsets.
-Matthias On 4/11/20 6:56 AM, SenthilKumar K 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 >
signature.asc
Description: OpenPGP digital signature
