Re: Strange rebalancing exception in Kafka 1.0.0

2017-12-14 Thread Sameer Kumar
Hi All, This is only reproducible when I have 3 nodes in my cluster even in the start of the app, everything works fine on 2 nodes. I have tried this again and faced the same error, this time I increased MAX_PARTITION_FETCH_BYTES_CONFIG to 10MB from default 1MB, still getting the same error. Any

Re: Strange rebalancing exception in Kafka 1.0.0

2017-12-12 Thread Sameer Kumar
Hi All, Any pointers to the above issue that I can explore further. -Sameer. On Tue, Dec 12, 2017 at 5:40 PM, Sameer Kumar wrote: > HI Ismael, > > This is what I see in the logs, I tried this twice and got the same > exception. > > This is only reproducible when I have 3 nodes in my cluster ev

Re: Strange rebalancing exception in Kafka 1.0.0

2017-12-12 Thread Sameer Kumar
HI Ismael, This is what I see in the logs, I tried this twice and got the same exception. This is only reproducible when I have 3 nodes in my cluster even in the start of the app, everything works fine on 2 nodes. [2017-12-12 17:28:36,822] INFO [GroupCoordinator 90]: Preparing to rebalance group

Re: Strange rebalancing exception in Kafka 1.0.0

2017-12-12 Thread Ismael Juma
Can you please check the broker logs for errors? Ismael On Tue, Dec 12, 2017 at 12:10 PM, Sameer Kumar wrote: > Hi All, > > Facing an strange exception while running Kafka Streams. I am reading from > a topic of 60 partitions. I am using exactly once in Kafka 1.0.0. > > Now, this error has star

Strange rebalancing exception in Kafka 1.0.0

2017-12-12 Thread Sameer Kumar
Hi All, Facing an strange exception while running Kafka Streams. I am reading from a topic of 60 partitions. I am using exactly once in Kafka 1.0.0. Now, this error has started appearing recently. The application runs fine on 2 nodes, but as soon as a 3rd node is added, it starts throwing excepti