kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Piotr Husiatyński <...@optiopay.com>
Subject Re: Fetch API Offset
Date Tue, 21 Apr 2015 13:47:26 GMT
What do you mean that message has expired?

If I will do fetch request with offset 4, I will receive first message
with offset 5. I think fetch is always excluding requested offset,
while documentation is saying it will be included in response.

On Tue, Apr 21, 2015 at 3:35 PM, Manoj Khangaonkar
<khangaonkar@gmail.com> wrote:
> Hi,
>
> I suspect If some message from the given offset have expired, then they
> will not be returned.
>
> regards
>
> On Tue, Apr 21, 2015 at 5:14 AM, Piotr Husiatyński <phu@optiopay.com> wrote:
>
>> According to documentation, sending fetch request with offset value
>> result in messages starting with given offset (including) and greater.
>>
>>
>> https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-FetchAPI
>>
>> > Logically one specifies the topics, partitions, and starting offset at
>> which to begin the fetch and gets back a chunk of messages. In general, the
>> return messages will have offsets larger than or equal to the starting
>> offset
>>
>> I'm sending fetch request with offset 5 and first message I'm getting
>> is offset 6. Am I doing something wrong or documentation has to be
>> fixed?
>>
>
>
>
> --
> http://khangaonkar.blogspot.com/

Mime
View raw message