Hi,
I'm trying to test the new java KafkConsumer (for use with 0.8.3) and have
pulled the code from trunk, but for me the following just ends up hanging
indefinitely.
Map<String, Object> props = new HashMap();
props.put("bootstrap.servers", "broker1:2181");
props.put("key.deserializer»,
"org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer",
"org.apache.kafka.common.serialization.StringDeserializer");
props.put("group.id", "test-" + new Random().nextInt());
KafkaConsumer consumer = new KafkaConsumer(props);
consumer.subscribe(topic);
ConsumerRecords<String, V> poller = consumer.poll(100);
poller.forEach(c -> queue.add(c.value()));
I'm able to read from the the topic using kafka-consumer.sh
Is this a know problem, work in progress or my bad in some way or another?
It seems to be hanging while it is trying to update metadata which is for some
reason never updated.
Regards
Espen
