Kafka invalid leader

[manoj sharma <ma...@gmail.com>]

Hi ,

I have a situation .

i have 3 broker(id) ==> 58,57,56,

some how broker 57 went invalid



hduser@node01:~$ kafka-topics --zookeeper node01:2181,node02:2181,rac1:2181
--describe

Topic:clouder PartitionCount:1 ReplicationFactor:2 Configs:
Topic: clouder Partition: 0 Leader: 56 Replicas: 56,57 Isr: 56
Topic:truckevent PartitionCount:2 ReplicationFactor:1 Configs:
Topic: truckevent Partition: 0 Leader: -1 Replicas: 57 Isr: 57
Topic: truckevent Partition: 1 Leader: 56 Replicas: 56 Isr: 56



 i moved to replica from 57 to 58



root@node01:/opt/TruckEvents# kafka-topics --zookeeper
node01:2181,node02:2181,rac1:2181 --describe
Topic:clouder PartitionCount:1 ReplicationFactor:2 Configs:
Topic: clouder Partition: 0 Leader: 56 Replicas: 56,57 Isr: 56
Topic:truckevent PartitionCount:2 ReplicationFactor:2 Configs:
Topic: truckevent Partition: 0 Leader: -1 Replicas: 58,57 Isr: 57
Topic: truckevent Partition: 1 Leader: 56 Replicas: 56 Isr: 56



but i also want to move leadership to 58 and tried



root@node01:/opt/TruckEvents# kafka-preferred-replica-election --zookeeper
node01:2181,node02:2181,rac1:2181
Successfully started preferred replica election for partitions
Set([truckevent,1], [truckevent,0], [clouder,0])

nothing changed and Leader is still 57 .



how can we change the leader is its invaid ?


-- 
Manoj