Andrei Zhabinski

Thanks for this update! However, before you continue please note that latest development has moved to [RDKafka.jl](https://github.com/dfdx/RDKafka.jl) which wraps very mature C client [librdkafka](https://github.com/edenhill/librdkafka) and, most importantly, covers new producer...

I checked out Kafka 1.0 (Scala 2.12), but it doesn't send response to my metadata request. It seems like the protocol has changed (despite stated backward compatibility). I will take...

Ok, I was looking in the wrong place: on Julia 0.5 this package works fine on Kafka 0.9, 0.10 and 1.0. But on Julia 0.6 it magically stops working with...

I think I have fixed it. The problem was in request size calculation: to tell Kafka how long the request is I used: ``` function obj_size(objs...) buf = IOBuffer() for...

Done, master now supports Julia 0.6 and Kafka from 0.8 to 1.0. Would you mind rebasing and making a PR to fix deprecation according to work in your fork?

Yes, it's most likely related to leader selection, but I need to check it out. I'll try to do it over the weekend.

It seems like mistakes from early days of my Julia experience when Kafka.jl was created start catching me. `KafkaClient` creates a separate coroutine to handle responses from each broker's connection,...

Just to make it explicit and ensure we are on the same page: this also implies that you need offset management, i.e. consumers should commit their offsets after reading to...

No, it isn't expected and I can't see where it comes from: the message suggests that it's an issue with type inference inside Julia itself happening in `atexit` hook, but...

Hm, I can't reproduce this error. I tried: * Julia 0.6.0 and 0.6.2 (not JuliaPro, though) * from REPL and using `julia test.jl` * both snippets - with Kafka.jl at...