Thanks a lot, ZkStringSerializer works like a charm!
For those googling for the same question, here's a gist, which
instantiates ZkClient and sets proper serializer (in case somebody else
finds this question).
[1]: https://gist.github.com/jjkoshy/3842975
On Tue, Apr 7, 2015 at 6:49 PM, Guozhang
Andrei,
Kafka uses string serialization when writing data to ZK, you can find its
implementation in kafka.utils.ZKStringSerializer.
Guozhang
On Tue, Apr 7, 2015 at 6:40 AM, Andrei wrote:
> I'm trying to read data from ZooKeeper nodes that was written by different
> Kafka components. As a speci
You need to create the ZKClient with the kafka.utils.ZkStringSerializer as
the serializer.
On Tue, Apr 7, 2015 at 9:40 AM, Andrei wrote:
> I'm trying to read data from ZooKeeper nodes that was written by different
> Kafka components. As a specific example (just one from a bunch), I'm trying
> to
I'm trying to read data from ZooKeeper nodes that was written by different
Kafka components. As a specific example (just one from a bunch), I'm trying
to read current offset for specific group, topic and partition. As far as I
understand, it is stored under the path
/consumers/data-processing-
