Consumer - Failed to find leader

2015-12-27 Thread prabhu v
Hi Experts, I am getting the below error when running the consumer "kafka-console-consumer.sh" . I am using the new version 0.9.0.1. Topic name: test [2015-12-28 06:13:34,409] WARN [console-consumer-61657_localhost-1451283204993-5512891d-leader-finder-thread], Failed to find leader for Set([tes

Re: kafka.common.LeaderNotAvailableError

2015-12-27 Thread Dana Powers
Hi David - did you see my response on the earlier thread? Let me know if this is a different issue. http://mail-archives.apache.org/mod_mbox/kafka-users/201512.mbox/%3CCAKRFjjVZ7u4vnnMiPzxGc_oYYnnBqNjAGpfkC8GLj6MdLUvq6w%40mail.gmail.com%3E -Dana On Dec 27, 2015 3:08 AM, "David Montgomery" wrote:

Re: Gradle build error

2015-12-27 Thread Oliver Pačut
I have Gradle 1.4, Groovy 1.8.6, Ant 1.9.3. I followed the included Readme. I cd'd to the kafka directory and just wrote "gradle". I also tried running "./bin/kafka-server-start.sh ./config/server.properties" And that gets me the error "Could not find or load main class Kafka.kafka" Oliver

kafka.common.LeaderNotAvailableError

2015-12-27 Thread David Montgomery
H. Why do I get the below when I use python kafka? Is this a buggy client? LeaderNotAvailableError: PartitionMetadata(topic='topic-impression-production', partition=0, leader=-1, replicas=(), isr=(), error=5) What is most disturbing I get the below when I run describe from the command line.