kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <mj...@apache.org>
Subject Re: Process offsets from particular point
Date Sat, 11 Apr 2020 18:52:53 GMT
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, <mdkhajaasmath@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
> 


Mime
View raw message