Exception kafka.common.NotLeaderForPartitionException

2014-05-29 Thread Bhavesh Mistry
Hi Kafka User Group, We have recently changed the “message.max.bytes” to 2MB and rebooted all the brokers at once. After this, we are getting “kafka.common.NotLeaderForPartitionException” on both Producer side and consumer side. How do I fix this, I have restarted producer and consumer

Re: Exception kafka.common.NotLeaderForPartitionException

2014-05-29 Thread Guozhang Wang
Bhavesh, This exception is usually normal and transient upon broker restarts. Do you still see them after restarting the brokers for a while? Guozhang On Thu, May 29, 2014 at 6:02 PM, Bhavesh Mistry mistry.p.bhav...@gmail.com wrote: Hi Kafka User Group, We have recently changed the

Re: Exception kafka.common.NotLeaderForPartitionException

2014-05-29 Thread Bhavesh Mistry
Hi Guozhang Wang, I restarted the Broker yesterday, and I am still seeing this exception on consumer and producer sides. Thanks, Bhavesh On Thu, May 29, 2014 at 8:14 PM, Guozhang Wang wangg...@gmail.com wrote: Bhavesh, This exception is usually normal and transient upon broker restarts. Do