i, I have 3 ZK servers and 2 kafka servers with 2 partitions.
I am using kafka_2.11-0.8.2.1 Here is how I am creating a topic: bin/kafka-topics.sh --zookeeper 1.zk.do.production.test:2181,2.zk.do.production.test:2181,3.zk.do.production.test:2181 --create --topic topic-test-production --partitions 2 --replication-factor 2 here is what I describe: bin/kafka-topics.sh --zookeeper .zk.do.production.test:2181,2.zk.do.production.test:2181,3.zk.do.production.test:2181 --describe --topic topic-test-production Topic:topic-test-production PartitionCount:2 ReplicationFactor:2 Configs: Topic: topic-test-production Partition: 0 Leader: none Replicas: 26665,2028 Isr: Topic: topic-test-production Partition: 1 Leader: none Replicas: 2028,26665 Isr: When i try to write to kafka in python I get this error. kafka.common.LeaderNotAvailableError: TopicMetadata(topic='topic-test-production', error=5, partitions=[]) What is wrong with kafka? Thanks