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). 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/apac >>he >> /kafka/clients/consumer/KafkaConsumer.java#L634 >> >><https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apa >>che/kafka/clients/consumer/KafkaConsumer.java#L634> >> >> >> >>https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apac >>he >> /kafka/clients/consumer/KafkaConsumer.java#L553 >> >><https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apa >>che/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
