Hi, I am looking at the java class org.apache.kafka.clients.consumer.ConsumerConfig and I do not see there a constant for offsets.storage
Am I missing something? This is my pom dependency definition: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.8.2.1</version> </dependency> On Wed, Apr 8, 2015 at 6:29 PM, Gwen Shapira <gshap...@cloudera.com> wrote: > This is available from 0.8.2.0, and is enabled on server by default. The > consumer needs to specify offsets.storage parameter - the default is still > zookeeper, so the consumers should set it to 'kafka'. > > The documentation also explain how to migrate from zookeeper offsets to > kafka offsets. > > Gwen > > On Wed, Apr 8, 2015 at 8:13 AM, Yosi Botzer <yosi.bot...@gmail.com> wrote: > > > Hi, > > > > I have seen this presentation: > > http://www.slideshare.net/jjkoshy/offset-management-in-kafka > > > > describing a new approach for offset management. > > > > I wanted to know from which kafka version this option will be available > and > > will it be available by default > > > > Thanks > > Yosi > > >
