kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: Getting offset from ConsumerIterator
Date Fri, 06 Apr 2012 01:12:09 GMT

Yes, currently, you would have to use SimpleConsumer. It's possible to add
the offset support in the ZK consumer in the future. We just haven't found
a proper api yet.



On Thu, Apr 5, 2012 at 2:27 PM, Edward Buck <egbuck@hotmail.com> wrote:

> In my consumer, I would like to be able to re-request a message at a
> specific offset. However, the ConsumerIterator does not appear to expose
> the message offset when you call next(). In order to get an offset for each
> message, is it necessary to use a SimpleConsumer (the low-level API),
> rather than KafkaMessageStream (the high-level API)?Thanks,Ed

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