As you can see in the javadoc for KafkaConsumer, you need to call poll() in
a loop. Something like:
while (true) {
* ConsumerRecords records = consumer.poll(100);
* records.forEach(c -> queue.add(c.value()));
*
* }
On Tue, Aug 18, 2015 at 2:46 AM, Krogh-Moe, Espen
wrote:
>
Hi,
I'm trying to test the new java KafkConsumer in 0.8.3 and have pulled the code
from trunk, but for me the following just ends up hanging indefinitely.
Map props = new HashMap();
props.put("bootstrap.servers", "broker1:2181");
props.put("key.deserializer»,
"org.apache.kafka.common.serializ
