Ok sorry I think I was confused. Once I have the offset, say I have the first offset (would it be 0?), I then call consume and it gets me the next message, and I keep calling consume till it reaches the end.
On Mon, May 7, 2012 at 9:52 AM, Sebastian Eichner <m...@sebastian-eichner.de > wrote: > On Mon, May 7, 2012 at 3:47 PM, S Ahmed <sahmed1...@gmail.com> wrote: > > Is it possible to query for a list of offsets? > > Your Ruby Consumer has exactly 1 offset. You can query it via > consumer.offset (maybe take a look at the gem's sourcecode, its easy > to understand). > > > From what I understand, each offset is not for a single message, but > could > > be a group of messages right? > > Not sure what you are referring to, but maybe you mix up the info on > the Java Consumer, which handles multiple streams in parallel (and > then does have multiple offsets). The Ruby consumer is much simpler > (like the Java SimpleConsumer) and just works single-threaded with one > offset. > > Sebastian >
