You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Jonathan Santilli <jo...@gmail.com> on 2018/07/14 10:43:27 UTC

Error while creating ephemeral at /brokers/ids/BROKER_ID

Hello, hope you all are Ok,

I would like to know if this is the expected behavior:

ERROR Error while creating ephemeral at /brokers/ids/BROKER_ID, node
already exists and owner '*216186131422332301*' does not match current
session '*288330817911521280*' (kafka.zk.KafkaZkClient$CheckedEphemeral)

INFO Result of znode creation at /brokers/ids/BROKER_ID is: NODEEXISTS
(kafka.zk.KafkaZkClient)

ERROR Uncaught exception in scheduled task 'isr-expiration'
(kafka.utils.KafkaScheduler)


After that, the logs keep showing constantly the following:


INFO [Partition TOPIC_NAME-PARTITION-ID broker=BROKER_ID] Shrinking ISR
from 1,3,2 to 1 (kafka.cluster.Partition)
INFO [Partition TOPIC_NAME-PARTITION-ID broker=BROKER_ID Cached zkVersion
[0] not equal to that in zookeeper, skip updating ISR
(kafka.cluster.Partition)
INFO [Partition __consumer_offsets-PARTITION-ID broker=BROKER_ID] Shrinking
ISR from 1,2,3 to 1 (kafka.cluster.Partition)
INFO [Partition __consumer_offsets-PARTITION-ID broker=BROKER_ID] Cached
zkVersion [139] not equal to that in zookeeper, skip updating ISR
(kafka.cluster.Partition)


The only way to recover was restarting the Broker.

I will really appreciate any clue about this error,


Cheers!
-- 
Santilli Jonathan

Re: Error while creating ephemeral at /brokers/ids/BROKER_ID

Posted by Jonathan Santilli <jo...@gmail.com>.

Thanks a lot for your reply Ismael, I have filled the JIRA:
https://issues.apache.org/jira/browse/KAFKA-7165

Cheers!
--
Jonathan




On Sat, Jul 14, 2018 at 5:25 PM Ismael Juma <is...@juma.me.uk> wrote:

> Hi Jonathan,
>
> Can you please file a JIRA?
>
> Ismael
>
> On Sat, Jul 14, 2018 at 3:44 AM Jonathan Santilli <
> jonathansantilli@gmail.com> wrote:
>
> > Hello, hope you all are Ok,
> >
> > I would like to know if this is the expected behavior:
> >
> > ERROR Error while creating ephemeral at /brokers/ids/BROKER_ID, node
> > already exists and owner '*216186131422332301*' does not match current
> > session '*288330817911521280*' (kafka.zk.KafkaZkClient$CheckedEphemeral)
> >
> > INFO Result of znode creation at /brokers/ids/BROKER_ID is: NODEEXISTS
> > (kafka.zk.KafkaZkClient)
> >
> > ERROR Uncaught exception in scheduled task 'isr-expiration'
> > (kafka.utils.KafkaScheduler)
> >
> >
> > After that, the logs keep showing constantly the following:
> >
> >
> > INFO [Partition TOPIC_NAME-PARTITION-ID broker=BROKER_ID] Shrinking ISR
> > from 1,3,2 to 1 (kafka.cluster.Partition)
> > INFO [Partition TOPIC_NAME-PARTITION-ID broker=BROKER_ID Cached zkVersion
> > [0] not equal to that in zookeeper, skip updating ISR
> > (kafka.cluster.Partition)
> > INFO [Partition __consumer_offsets-PARTITION-ID broker=BROKER_ID]
> Shrinking
> > ISR from 1,2,3 to 1 (kafka.cluster.Partition)
> > INFO [Partition __consumer_offsets-PARTITION-ID broker=BROKER_ID] Cached
> > zkVersion [139] not equal to that in zookeeper, skip updating ISR
> > (kafka.cluster.Partition)
> >
> >
> > The only way to recover was restarting the Broker.
> >
> > I will really appreciate any clue about this error,
> >
> >
> > Cheers!
> > --
> > Santilli Jonathan
> >
>


-- 
Santilli Jonathan

Re: Error while creating ephemeral at /brokers/ids/BROKER_ID

Posted by Ismael Juma <is...@juma.me.uk>.

Hi Jonathan,

Can you please file a JIRA?

Ismael

On Sat, Jul 14, 2018 at 3:44 AM Jonathan Santilli <
jonathansantilli@gmail.com> wrote:

> Hello, hope you all are Ok,
>
> I would like to know if this is the expected behavior:
>
> ERROR Error while creating ephemeral at /brokers/ids/BROKER_ID, node
> already exists and owner '*216186131422332301*' does not match current
> session '*288330817911521280*' (kafka.zk.KafkaZkClient$CheckedEphemeral)
>
> INFO Result of znode creation at /brokers/ids/BROKER_ID is: NODEEXISTS
> (kafka.zk.KafkaZkClient)
>
> ERROR Uncaught exception in scheduled task 'isr-expiration'
> (kafka.utils.KafkaScheduler)
>
>
> After that, the logs keep showing constantly the following:
>
>
> INFO [Partition TOPIC_NAME-PARTITION-ID broker=BROKER_ID] Shrinking ISR
> from 1,3,2 to 1 (kafka.cluster.Partition)
> INFO [Partition TOPIC_NAME-PARTITION-ID broker=BROKER_ID Cached zkVersion
> [0] not equal to that in zookeeper, skip updating ISR
> (kafka.cluster.Partition)
> INFO [Partition __consumer_offsets-PARTITION-ID broker=BROKER_ID] Shrinking
> ISR from 1,2,3 to 1 (kafka.cluster.Partition)
> INFO [Partition __consumer_offsets-PARTITION-ID broker=BROKER_ID] Cached
> zkVersion [139] not equal to that in zookeeper, skip updating ISR
> (kafka.cluster.Partition)
>
>
> The only way to recover was restarting the Broker.
>
> I will really appreciate any clue about this error,
>
>
> Cheers!
> --
> Santilli Jonathan
>