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

Posted to users@kafka.apache.org by Manish <ma...@gmail.com> on 2014/11/15 02:04:48 UTC

shrinking isr for partitions followed by error.. (kafka 0.8.1.1)

I had deleted the topic "sams_2014-10-30" successfully, and later on one of
our kafka brokers (broker id 4) crashed,

Now the topic is gone from zookeeper

ls /brokers/topics

(doesn't show the topic anymore)


but I still see the zookeeper logs filling up with these messages.. :


[2014-11-14 16:57:27,837] INFO Partition [sams_2014-10-30,7] on broker 0:
Shrinking ISR for partition [sams_2014-10-30,7] from 0,4 to 0
(kafka.cluster.Partition)

[2014-11-14 16:57:27,907] ERROR Conditional update of path
/brokers/topics/sams_2014-10-30/partitions/7/state with data
{"controller_epoch":20,"leader":0,"version":1,"leader_epoch":7,"isr":[0]}
and expected version 490 failed due to
org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode =
NoNode for /brokers/topics/sams_2014-10-30/partitions/7/state
(kafka.utils.ZkUtils$)



any ideas?

Re: shrinking isr for partitions followed by error.. (kafka 0.8.1.1)

Posted by Manish <ma...@gmail.com>.

correction server.log ( not zookeeper logs. )

On Fri, Nov 14, 2014 at 5:04 PM, Manish <ma...@gmail.com> wrote:

> I had deleted the topic "sams_2014-10-30" successfully, and later on one
> of our kafka brokers (broker id 4) crashed,
>
> Now the topic is gone from zookeeper
>
> ls /brokers/topics
>
> (doesn't show the topic anymore)
>
>
> but I still see the zookeeper logs filling up with these messages.. :
>
>
> [2014-11-14 16:57:27,837] INFO Partition [sams_2014-10-30,7] on broker 0:
> Shrinking ISR for partition [sams_2014-10-30,7] from 0,4 to 0
> (kafka.cluster.Partition)
>
> [2014-11-14 16:57:27,907] ERROR Conditional update of path
> /brokers/topics/sams_2014-10-30/partitions/7/state with data
> {"controller_epoch":20,"leader":0,"version":1,"leader_epoch":7,"isr":[0]}
> and expected version 490 failed due to
> org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode =
> NoNode for /brokers/topics/sams_2014-10-30/partitions/7/state
> (kafka.utils.ZkUtils$)
>
>
>
> any ideas?
>
>
>

Re: shrinking isr for partitions followed by error.. (kafka 0.8.1.1)

Posted by Jun Rao <ju...@gmail.com>.

We fixed a bunch of issues related to delete topic in 0.8.2. Could you try
the 0.8.2 beta release?

Thanks,

Jun

On Fri, Nov 14, 2014 at 5:04 PM, Manish <ma...@gmail.com> wrote:

> I had deleted the topic "sams_2014-10-30" successfully, and later on one of
> our kafka brokers (broker id 4) crashed,
>
> Now the topic is gone from zookeeper
>
> ls /brokers/topics
>
> (doesn't show the topic anymore)
>
>
> but I still see the zookeeper logs filling up with these messages.. :
>
>
> [2014-11-14 16:57:27,837] INFO Partition [sams_2014-10-30,7] on broker 0:
> Shrinking ISR for partition [sams_2014-10-30,7] from 0,4 to 0
> (kafka.cluster.Partition)
>
> [2014-11-14 16:57:27,907] ERROR Conditional update of path
> /brokers/topics/sams_2014-10-30/partitions/7/state with data
> {"controller_epoch":20,"leader":0,"version":1,"leader_epoch":7,"isr":[0]}
> and expected version 490 failed due to
> org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode =
> NoNode for /brokers/topics/sams_2014-10-30/partitions/7/state
> (kafka.utils.ZkUtils$)
>
>
>
> any ideas?
>