Re: Why does the high level consumer block, or rather where does it?

Yes, ConsumerIterator blocks when there is no new message. This is done by calling take() on a blocking queue. Thanks, Jun On Sun, Jan 5, 2014 at 5:53 PM, S Ahmed wrote: > I'm trying to trace through the codebase and figure out where exactly the > block occurs in the high level consumer? > >

Why does the high level consumer block, or rather where does it?

I'm trying to trace through the codebase and figure out where exactly the block occurs in the high level consumer? public void run() { ConsumerIterator it = m_stream.iterator(); while (it.hasNext()) System.out.println("Thread " + m_threadNumber + ": " + new String(it.next().mess

Re: Is this the right official logo for Apache Kafka?

That's right. On Jan 5, 2014 2:45 PM, "Menka" wrote: > http://upload.wikimedia.org/wikipedia/commons/f/f7/Apache_kafka.png > > Please help me confirm. > > Thanks, > Menka > > > > -- > Blog: http://menkag.blogspot.com > Facebook: http://www.facebook.com/MenkasJewelry > > "Don't let what you cannot

Is this the right official logo for Apache Kafka?

http://upload.wikimedia.org/wikipedia/commons/f/f7/Apache_kafka.png Please help me confirm. Thanks, Menka -- Blog: http://menkag.blogspot.com Facebook: http://www.facebook.com/MenkasJewelry "Don't let what you cannot do interfere with what you can do" - by John Wooden