Re: Kafka Protocol API versions

2016-05-17 Thread Ismael Juma
Hi Dana, One comment below. On Tue, May 17, 2016 at 2:39 PM, Dana Powers wrote: > (myself). Asish or others can correct me if I'm wrong here, but I > believe the java client is not attempting to do this yet outside of a > single request flow (SASL authentication). > The Java client is not usin

Re: Kafka Protocol API versions

2016-05-17 Thread Dana Powers
I'd also add that there is some discussion of the mixed-broker issue on the KIP-35 wiki page as well: https://cwiki.apache.org/confluence/display/KAFKA/KIP-35+-+Retrieving+protocol+version#KIP-35-Retrievingprotocolversion-Aclientdeveloperwantstoaddsupportforanewfeature Of course, since 0.9 (and e

Re: Kafka Protocol API versions

2016-05-17 Thread Ismael Juma
Hi Oleksiy, Ashish has just created a PR to add some information about how to use KIP-35: https://github.com/apache/kafka/pull/1395 Maybe you can have a look and leave a comment with areas that are not covered by the first draft. Ismael On Tue, May 17, 2016 at 1:34 PM, Oleksiy Krivoshey wrote

Kafka Protocol API versions

2016-05-17 Thread Oleksiy Krivoshey
Given lots of protocol changes in 0.10 compared to 0.9, with many API methods now having up to 3 possible versions, what is the suggested way for the client library to coordinate with Kafka brokers? I can see there is ApiVersions request which is great, but what happens if Kafka cluster consists of