Yes it is supported in 0.8.2-beta. It is documented on the site - you will need to set offsets.storage to kafka.
On Thu, Feb 19, 2015 at 03:57:31PM -0500, Matthew Butt wrote: > I'm having a hard time figuring out if the new Kafka-based offset > management in the high-level Scala Consumer is implemented in the current > version of 0.8.2-beta. If I implement a high-level consumer, will it use > the new system, or will it still be storing in zookeeper? Do I need to wait > for the Java consumer to take advantage of it? > > -- > - Matt
