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 “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 application but not able to resolve this issue. We are on Kafka > version 0.8.0 and this issue is fixed on 0.8.0. Please let me know how to > fix this issue. Thanks in advance for your help !! > > > > Here is sample log: > > > > WARN warn, Produce request with correlation id 1166 failed due to > [logmon.rawlog,15]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 1170 failed due to > [logmon.rawlog,26]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 1208 failed due to > [logmon.rawlog,23]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 650 failed due to > [logmon.heartbeat,0]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 1229 failed due to > [logmon.rawlog,23]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 1237 failed due to > [logmon.rawlog,29]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 1245 failed due to > [logmon.rawlog,18]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 1253 failed due to > [logmon.rawlog,18]: *kafka.common.NotLeaderForPartitionException* > > ERROR error, Failed to send requests for topics logmon.rawlog with > correlation ids in [1222,1254] > > ERROR error, Error in handling batch of 6 events > > WARN warn, Produce request with correlation id 1271 failed due to > [logmon.rawlog,3]: *kafka.common.NotLeaderForPartitionException* > > WARN warn, Produce request with correlation id 1283 failed due to > [logmon.rawlog,11]: *kafka.common.NotLeaderForPartitionException* > > Thanks, > Bhavesh > -- -- Guozhang
