kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: Exception kafka.common.NotLeaderForPartitionException
Date Fri, 30 May 2014 03:14:27 GMT
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.bhavesh@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

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