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/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!
