New KafkaConsumer is not yet released. It is planned for 0.9.0 release.
On 2/13/15, Jayesh Thakrar <j_thak...@yahoo.com.invalid> wrote: > Hi, > I am trying to write a consumer using the KafkaConsumer class > from > https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java. > My code is pretty simple with the snippet show below.However what I am > seeing is that I am not seeing any data out and the "records" variable is > null.I know I have data in the topic as I "pushed" data just before running > this example using the console writer that comes bundled with Kafka. > > public static void main(String[] args) { Properties props > = new Properties(); props.put("metadata.broker.list", > "dtord01hdp0101d.int:9092"); props.put("bootstrap.servers", > "dtord01hdp0101d.int:9092"); > props.put("partition.assignment.strategy", "roundrobin"); > props.put("group.id", "test"); props.put("session.timeout.ms", > "1000"); props.put("enable.auto.commit", "true"); > props.put("auto.commit.interval.ms", "10000"); KafkaConsumer > consumer = new KafkaConsumer(props); consumer.subscribe("*"); > boolean isRunning = true; while(isRunning) { > Map<String, ConsumerRecords> records = consumer.poll(100); > System.out.println(records.keySet().size()); } > consumer.close(); } > > >
