Yep, that was it ...
Everything works now. And the only thing that didn't, earlier, was my head.
Thanks all!
-Joris.
-Original Message-
From: noah [mailto:iamn...@gmail.com]
Sent: 22 September 2015 12:17
To: users@kafka.apache.org
Subject: Re: committing offsets
If you are usin
gt; -Original Message-
> From: tao xiao [mailto:xiaotao...@gmail.com]
> Sent: 22 September 2015 10:51
> To: users@kafka.apache.org
> Subject: Re: committing offsets
>
> 0.8.2.1 already supports Kafka offset storage. You can set
> offsets.storage=kafka in consumer propert
'java -jar ...' with no
logging config).
-J
-Original Message-
From: tao xiao [mailto:xiaotao...@gmail.com]
Sent: 22 September 2015 10:51
To: users@kafka.apache.org
Subject: Re: committing offsets
0.8.2.1 already supports Kafka offset storage. You can set
offsets.storage=kafka in
0.8.2.1 already supports Kafka offset storage. You can
set offsets.storage=kafka in consumer properties and high level API is able
to pick it up and commit offsets to Kafka
Here is the code reference where kafka offset logic kicks in
https://github.com/apache/kafka/blob/0.8.2/core/src/main/scala/k
