Yes, it knows. The consumer offset is only advanced every time a message is
iterated over.
Thanks,
Jun
On Wed, Jul 11, 2012 at 10:03 PM, Vaibhav Puranik <vpura...@gmail.com>wrote:
> The inner loop keeps running. If I break it in the middle, is Kafka broker
> going to know that rest of the mesaages in the stream were not delivered?
>
> Regards,
> Vaibhav
> GumGum
> On Jul 11, 2012 5:05 PM, "Vaibhav Puranik" <vpura...@gmail.com> wrote:
>
> > Hi all,
> >
> > Is there any way to get a fixed amount of messages using Zookeeper based
> > consumer (ConsumerConnector)?
> >
> > I know that with SimpleConsumer you can pass fetchSize as an argument and
> > limit the number of messages coming back.
> >
> > This sample code creates 4 threads that keep consuming forever.
> >
> >
> > // consume the messages in the threads
> > for(final KafkaStream<Message> stream: streams) {
> > executor.submit(new Runnable() {
> > public void run() {
> > for(MessageAndMetadata msgAndMetadata: stream) {
> > // process message (msgAndMetadata.message())
> > }
> > }
> > });
> > }
> >
> > Regards,
> > Vaibhav
> >
> >
> >
>
