Re: Same leader for all partitions for topics

2016-10-07 Thread David Garcia
Maybe someone already answered this…but you can use the repartitioner to fix that (it’s included with Kafka) As far as root cause, you probably had a few leader elections due to excessive latency. There is a cascading scenario that I noticed Kafka is vulnerable to. The events transpire as fol

Same leader for all partitions for topics

2016-10-07 Thread Misra, Rahul
Hi, I have been using a 3 node kafka cluster for development for some time now. I have created some topics on this cluster. Yesterday I observed the following when I used 'describe' for the topics: The Kafka version I'm using is: 9.0.1 (kafka_2.11-0.9.0.1). Topic:topicIc PartitionCount:3