Re: KafkaStreams: ProducerFencedException causing StreamThread death

2018-09-30 Thread Guozhang Wang
Could you take a look at https://issues.apache.org/jira/browse/KAFKA-7284 and see if you are hitting this? Guozhang On Fri, Sep 28, 2018 at 5:22 PM, Aravind Dongara wrote: > Hi Guozhang > > Thanks for your reply. > We are using Kafka 1.1.1 > > Thanks > Aravind > > > > On Sep 28, 2018, at 4:45

Re: Asking about how to consume the message from follower partition

2018-09-30 Thread Matthias J. Sax
Kafka scales via partitions, not via replication. Replication guarantees fault-tolerance. Thus, it's not possible atm, to consume from follower partitions -- also note, even if different consumer would read from follower partitions, each of them would read the same data. I assume, you want

Re: Asking about how to consume the message from follower partition

2018-09-30 Thread M. Manna
Have you set the bootstrap.servers to your local broker and check? Also, don’t forget that for any topic there’s a leader and follower - so asking the follower to do a leader’s job isn’t probably the correct intention. On Sun, 30 Sep 2018 at 17:06, Aung Myo Htut wrote: > Dear sir > > I'm

Asking about how to consume the message from follower partition

2018-09-30 Thread Aung Myo Htut
Dear sir I'm doing the project of streaming the image sequence using the Apache Kafka. Now I can stream with the single broker. To have the scalability, I want to use 3 Kafka Brokers with 3 replication and Brokers will be installed at different locations. So I want consumers to consume from the