represented by one offset?
Thanks,
Snehalata
- Original Message -
From: "Mayuresh Gharat"
To: users@kafka.apache.org
Sent: Friday, February 6, 2015 3:48:42 AM
Subject: Re: How to fetch old messages from kafka
If you see the code for getOffsetsBefore() :
/**
* Get a list of val
riginal Message -
> From: gharatmayures...@gmail.com
> To: users@kafka.apache.org
> Sent: Wednesday, February 4, 2015 11:24:46 AM
> Subject: Re: How to fetch old messages from kafka
>
> In that case you will have to maintain the offsets consumed and reset the
> offsets in c
es from any given valid offset returned from
> getOffsetBefore().
>
> is this correct approach?
>
> Thanks,
> Snehalata
>
> - Original Message -
> From: gharatmayures...@gmail.com
> To: users@kafka.apache.org
> Sent: Wednesday, February 4, 2015 11:24:46 AM
>
correct approach?
Thanks,
Snehalata
- Original Message -
From: gharatmayures...@gmail.com
To: users@kafka.apache.org
Sent: Wednesday, February 4, 2015 11:24:46 AM
Subject: Re: How to fetch old messages from kafka
In that case you will have to maintain the offsets consumed and reset the
In that case you will have to maintain the offsets consumed and reset the
offsets in case you need to consume from past.
For example, suppose you have a userA for which you have a partitionA for topic
TopicA. Each page shown to user increments the offset by 10. You have consumed
till offset 100
Hi ,
We are using kafka for storing messages in chat application.
Currently we divided each topic in multiple partitions. each partition stores
data for given customer who uses the application.
Right now on very first request, application fetches log from kafka from
earliest valid offset to
