Upgrading producers to 1.0

2017-11-27 Thread Brian Cottingham
When upgrading from 0.11 to 1.0, do I have to upgrade the library I used to write my producer? Or does the wire protocol change only affect brokers?

Re: Upgrading producers to 1.0

2017-11-27 Thread Matthias J. Sax
Since 0.10.2, you can upgrade your clients without upgrading your brokers. https://cwiki.apache.org/confluence/display/KAFKA/KIP-97%3A+Improved+Kafka+Client+RPC+Compatibility+Policy -Matthias On 11/27/17 11:44 AM, Brian Cottingham wrote: > When upgrading from 0.11 to 1.0, do I have to upgrade t

Re: Upgrading producers to 1.0

2017-11-27 Thread Brian Cottingham
On 11/27/17, 5:53 PM, "Matthias J. Sax" wrote: Since 0.10.2, you can upgrade your clients without upgrading your brokers. https://cwiki.apache.org/confluence/display/KAFKA/KIP-97%3A+Improved+Kafka+Client+RPC+Compatibility+Policy According to that doc, > New brokers support ol

Re: Upgrading producers to 1.0

2017-11-27 Thread Matthias J. Sax
Not sure were you exactly copied this. However, second paragraph here https://kafka.apache.org/documentation/#upgrade_10_2_0 explains: > Starting with version 0.10.2, Java clients (producer and consumer) have > acquired the ability to communicate with older brokers. Version 0.10.2 > clients can

Re: Upgrading producers to 1.0

2017-11-27 Thread Matthias J. Sax
Ah. I see. You copied from the KIP. The "Motivation" sections describes the state _before_ the change :) -Matthias On 11/27/17 5:36 PM, Matthias J. Sax wrote: > Not sure were you exactly copied this. However, second paragraph here > https://kafka.apache.org/documentation/#upgrade_10_2_0 explai

Re: My Docker Kafka image

2017-11-27 Thread David Luu
Does this have a github source repo for the docker image/file setup? or just only available for the final docker image in docker repo? On Sun, Nov 26, 2017 at 11:53 AM, Christian F. Gonzalez Di Antonio < christian...@gmail.com> wrote: > I would like to share my @apachekafka

Exception in rebalancing | Kafka 1.0.0

2017-11-27 Thread Sameer Kumar
hi all, Faced this exception yesterday, any possible reasons for the same. At the same time, one of the machines was restarted in my Kafka Streams cluster and hence the job ended there. Detailed exception trace is attached. I am using Kafka 1.0.0. 2017-11-28 00:07:38 ERROR Kafka010Base:46 - Exce

Re: Recommended settings for Internal Topics

2017-11-27 Thread Debraj Manna
Thanks Jakub. On Sun, Nov 26, 2017 at 4:20 AM, Jakub Scholz wrote: > When you use the default replication factor of 3 with single node broker > the offset and transaction topics will be never created. As a result > applications using them will not work (for example a consumer using the > offsets