kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bhavesh Mistry <mistry.p.bhav...@gmail.com>
Subject Exception kafka.common.NotLeaderForPartitionException
Date Fri, 30 May 2014 01:02:50 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message