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 Re: Exception kafka.common.NotLeaderForPartitionException
Date Fri, 30 May 2014 04:33:10 GMT
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 <wangguoz@gmail.com> wrote:

> 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