Re: Kafka 2.7.1 Rebalance failed DisconnectException

2021-07-18 Thread Daniel Meyer | !K7
Thanks, for following up on this, Tony. It's always super helpful to hear how things get resolved. -D On Fri, Jul 16, 2021 at 12:14 PM Tony John wrote: > Hi All, > > An update on this. Finally I could figure out the cause for this. I have a > consumer with *MAX_POLL_INTERVAL_MS_CONFIG* set to *I

Re: Kafka 2.7.1 Rebalance failed DisconnectException

2021-07-16 Thread Tony John
Hi All, An update on this. Finally I could figure out the cause for this. I have a consumer with *MAX_POLL_INTERVAL_MS_CONFIG* set to *Integer.MAX_VALUE*, which was causing the problem. Looks like its a combination of *group.initial.rebalance.delay.ms * in

Re: Kafka 2.7.1 Rebalance failed DisconnectException

2021-07-14 Thread Tony John
Hi Shilin, Thanks for the suggestion. But I am not upgrading an existing cluster. I've got a fresh broker and application cluster and there are no consumer offsets or topics present. When the app starts it creates the topics and once it moves to RUNNING state I see the rebalance failed log every 3

Re: Kafka 2.7.1 Rebalance failed DisconnectException

2021-07-14 Thread Shilin Wu
Depending on your original version, you may have to consult the upgrade guide. https://kafka.apache.org/27/documentation.html#upgrade Didn't see important compatibility settings like: [image: image.png] Perhaps you are not doing it correctly. [image: Confluent] Wu Sh

Re: Kafka 2.7.1 Rebalance failed DisconnectException

2021-07-14 Thread Tony John
Can someone help me on this. Thanks, Tony On Fri, Jul 9, 2021 at 8:15 PM Tony John wrote: > Hi All, > > I am trying to upgrade my Kafka streams application to 2.7.1 version of > Kafka. The brokers are upgraded to 2.7.1 and kafka dependencies are also on > 2.7.1. But when I start the application

Kafka 2.7.1 Rebalance failed DisconnectException

2021-07-09 Thread Tony John
Hi All, I am trying to upgrade my Kafka streams application to 2.7.1 version of Kafka. The brokers are upgraded to 2.7.1 and kafka dependencies are also on 2.7.1. But when I start the application, rebalance is failing with the following message Rebalance failed. org.apache.kafka.common.errors.Dis