The consumer iterator by default blocks if there are no new messages. You
can configure it to be non-blocking. See consumer.timeout.ms
http://kafka.apache.org/08/configuration.html
Thanks,
Jun
On Wed, Jul 10, 2013 at 11:55 PM, Ankit Jain wrote:
> Hi all,
>
> I have a Kafka 0.8 cluster of two n
Hi all,
I have a Kafka 0.8 cluster of two nodes on same machine with 4 partitions and
communicating through a single zookeeper.
I am producing data using the Kafka Producer using the following code:
KeyedMessage data = new KeyedMessage(topic,
input);
producer.send(data);
I am able to consume
