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-
49 PM, Guozhang Wang wrote:
> 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 da
@Piotr I can confirm that in native (Java/Scala) library returned message
offsets start with the one specified in request, not the next one. Note
sure about underlying protocol, though.
As long as you also know Python, I would suggest you looking at
kafka-python [1] library that is pretty readable
?
Thanks,
Andrei
Hello,
I am trying to replicate from
consumer: 0.9 using SSL
to producer: 0.11 over non-SSL.
However kafka mirroring always moves to non-ssl as consumer even if i
configure with ssl settings..etc.
Does anyone knows it kafka mirroring in 0.9 works as consumer over ssl?
Thanks,
Andrei
write a Python script with any libraries
installed, and I have full access to the Kafka endpoints from it.
Note: I understand the basic concepts, but I don't have a lot of
practical experience with Kafka (I've only used RabbitMQ before), so
apologies if my vocabulary is not very precise.
--
Florin Andrei
https://florin.myip.org/
iable?
--
Florin Andrei
https://florin.myip.org/
Hi all,
what is the oracle jdk version that is "supported" by kafka 0.9.0 ?
6/7/8...
ATTENTION:
The information in this e-mail is confidential and only meant for the intended
recipient. If you are not the intended recipient , don'
://kafka.apache.org/documentation.html#java
2016-01-28 16:58 GMT+01:00 Muresanu A.V. (Andrei Valentin) <
andrei.mures...@ing.ro>:
> Hi all,
>
> what is the oracle jdk version that is "supported" b
