kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: Fetch Response for invalid offset returns success.
Date Sat, 01 Mar 2014 05:25:43 GMT
You may have mis-understood the api. getOffsetsBefore() returns a valid
offset before a given timestamp, not a given offset.

Thanks,

Jun


On Fri, Feb 28, 2014 at 5:02 PM, Vadim Keylis <vkeylis2009@gmail.com> wrote:

> Hello Guozhang. The following is slightly modified version of the example.
> Where offset can be previously valid offset, but does not exist in kafka
> for one or the other valid reason.
> TopicAndPartition topicAndPartition = new TopicAndPartition(topic,
> partition);
>         Map<TopicAndPartition, PartitionOffsetRequestInfo> requestInfo =
> new HashMap<TopicAndPartition, PartitionOffsetRequestInfo>();
>         requestInfo.put(topicAndPartition, new
> PartitionOffsetRequestInfo(offset, 1));
>         kafka.javaapi.OffsetRequest request = new
> kafka.javaapi.OffsetRequest(
>                 requestInfo, (short) requiestedOffset,
> config.getGroupId());
>         OffsetResponse response = simpleConsumer.getOffsetsBefore(request);
>
>         if (response.hasError()) {
>                return;
>         }
>
>         long[] offsets = response.offsets(topic, partition);
>
>
>
>
> On Fri, Feb 28, 2014 at 4:36 PM, Guozhang Wang <wangguoz@gmail.com> wrote:
>
> > Hi Vadim,
> >
> > Which example in the kafka doc are you following?
> >
> > Guozhang
> >
> >
> > On Fri, Feb 28, 2014 at 3:18 PM, Vadim Keylis <vkeylis2009@gmail.com>
> > wrote:
> >
> > > Good afternoon. I am writing my own client that is based on simple
> > > consumer. I implemented method that is based on example in the kafka
> > > documents that sends request to kafka to find an offset. I am trying to
> > > find offsets after given offset. The api returns success even those
> > offset
> > > does not exist but offsets array has length of 0. What is the right way
> > to
> > > find next valid offset if the one been passed not found in Kafka.
> > >
> > > Thanks,
> > > Vadim
> > >
> >
> >
> >
> > --
> > -- Guozhang
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message