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").
On Tue, May 19, 2015 at 2:26 PM, Padgett, Ben <bpadg...@illumina.com> wrote: > 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 > <https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L634> > > > https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache > /kafka/clients/consumer/KafkaConsumer.java#L553 > <https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L553> > > > On 5/19/15, 2:13 PM, "Padgett, Ben" <bpadg...@illumina.com> wrote: > > >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.KafkaConsumer<String, String> consumer > >= new org.apache.kafka.clients.consumer.KafkaConsumer<String, > >String>(consumerProps); > > > >consumer.subscribe("project-created"); > > > >Map<String, ConsumerRecords<String, String>> records = consumer.poll(100); > >assertNotNull(records); > > > >``` > > > > > >If I run this from the command line I receive many records: > > > >``` > > > >bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic > >project-created --from-beginning > > > >``` > > > > > >When using the maven dependency below it appears the older scala packages > >are not available. > > > >``` > > > ><dependency> > > <groupId>org.apache.kafka</groupId> > > <artifactId>kafka-clients</artifactId> > > <version>0.8.2.0</version> > ></dependency> > > > >``` > > > >Is there a workaround for this? > > > >When is the next release expected to be released? > > > >Am I just using the consumer incorrectly? > > > >Thanks! > > -- Thanks, Ewen
