The new consumer is scheduled for 0.9.0. Currently Kafka release candidate 2 for 0.8.2.0 is being voted on.
There is an in progress patch to the new consumer that you can try out https://issues.apache.org/jira/browse/KAFKA-1760 /******************************************* Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> ********************************************/ On Fri, Jan 23, 2015 at 1:55 AM, Reeni Mathew <reenimathew...@gmail.com> wrote: > Hi Team, > > I was playing around with your recent release 0.8.2-beta. > Producer worked fine whereas new consumer did not. > > org.apache.kafka.clients.consumer.KafkaConsumer > > After digging the code I realized that the implementation for the same is > not available. Only API is present. > Could you please let me know by when we can expect the implementation of > the same. > > Thanks & Regards > > Reeni >