You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Matthew Butt <mb...@leadid.com> on 2015/02/19 21:57:31 UTC

New Consumer Offset management in 0.8.2

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

Re: New Consumer Offset management in 0.8.2

Posted by Joel Koshy <jj...@gmail.com>.

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