Re: KafkaConsumer poll always returns null

2015-05-20 Thread Ewen Cheslack-Postava
-Postava - do you have an example you could post? From: Ewen Cheslack-Postava [e...@confluent.io] Sent: Tuesday, May 19, 2015 3:12 PM To: users@kafka.apache.org Subject: Re: KafkaConsumer poll always returns null The new consumer in trunk is functional

RE: KafkaConsumer poll always returns null

2015-05-20 Thread Padgett, Ben
@Ewen Cheslack-Postava - do you have an example you could post? From: Ewen Cheslack-Postava [e...@confluent.io] Sent: Tuesday, May 19, 2015 3:12 PM To: users@kafka.apache.org Subject: Re: KafkaConsumer poll always returns null The new consumer in trunk

KafkaConsumer poll always returns null

2015-05-19 Thread Padgett, Ben
I came across this google group conversation that suggests KafkaConsumer will not be complete until the next release. (https://groups.google.com/forum/#!msg/kafka-clients/4VLb-_wI22c/imYRlxogo-kJ) ``` org.apache.kafka.clients.consumer.KafkaConsumerString, String consumer = new

Re: KafkaConsumer poll always returns null

2015-05-19 Thread Ewen Cheslack-Postava
The new consumer in trunk is functional when used similarly to the old SimpleConsumer, but none of the functionality corresponding to the high level consumer is there yet (broker-based coordination for consumer groups). There's not a specific timeline for the next release (i.e. when it's ready).

Re: KafkaConsumer poll always returns null

2015-05-19 Thread Padgett, Ben
The links below shows the code is definitely in trunk. Does anyone know when the source in trunk might be released? Thanks! https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache /kafka/clients/consumer/KafkaConsumer.java#L634

Re: KafkaConsumer poll always returns null

2015-05-19 Thread Padgett, Ben
Thanks! On 5/19/15, 3:12 PM, Ewen Cheslack-Postava e...@confluent.io wrote: The new consumer in trunk is functional when used similarly to the old SimpleConsumer, but none of the functionality corresponding to the high level consumer is there yet (broker-based coordination for consumer groups).