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 <p...@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/
