Could somebody help throw some light on why my commands might be hanging? What's the easiest way to monitor and debug this problem?
On Mon, Oct 13, 2014 at 5:07 PM, Mohit Anchlia <mohitanch...@gmail.com> wrote: > I am new to Kafka and I just installed Kafka. I am getting the following > error. Zookeeper seems to be running. > > [ec2-user@ip-10-231-154-117 kafka_2.10-0.8.1.1]$ > bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test > SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". > SLF4J: Defaulting to no-operation (NOP) logger implementation > SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further > details. > [2014-10-13 20:04:40,559] INFO Got user-level KeeperException when > processing sessionid:0x1490bea316f0000 type:setData cxid:0x37 > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error > Path:/config/topics/test Error:KeeperErrorCode = NoNode for > /config/topics/test (org.apache.zookeeper.server.PrepRequestProcessor) > [2014-10-13 20:04:40,562] INFO Got user-level KeeperException when > processing sessionid:0x1490bea316f0000 type:create cxid:0x38 > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error > Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics > (org.apache.zookeeper.server.PrepRequestProcessor) > [2014-10-13 20:04:40,568] INFO Topic creation > {"version":1,"partitions":{"1":[0],"0":[0]}} (kafka.admin.AdminUtils$) > [2014-10-13 20:04:40,574] INFO [KafkaApi-0] Auto creation of topic test > with 2 partitions and replication factor 1 is successful! > (kafka.server.KafkaApis) > [2014-10-13 20:04:40,650] INFO Closing socket connection to /127.0.0.1. > (kafka.network.Processor) > > > [2014-10-13 20:04:40,658] WARN Error while fetching metadata > [{TopicMetadata for topic test -> > No partition metadata for topic test due to > kafka.common.LeaderNotAvailableException}] for topic [test]: class > kafka.common.LeaderNotAvailableException > (kafka.producer.BrokerPartitionInfo) > > > > > [2014-10-13 20:04:40,661] INFO Got user-level KeeperException when > processing sessionid:0x1490bea316f0000 type:create cxid:0x43 > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error > Path:/brokers/topics/test/partitions/1 Error:KeeperErrorCode = NoNode for > /brokers/topics/test/partitions/1 > (org.apache.zookeeper.server.PrepRequestProcessor) > [2014-10-13 20:04:40,668] INFO Got user-level KeeperException when > processing sessionid:0x1490bea316f0000 type:create cxid:0x44 > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error > Path:/brokers/topics/test/partitions Error:KeeperErrorCode = NoNode for > /brokers/topics/test/partitions > (org.apache.zookeeper.server.PrepRequestProcessor) > [2014-10-13 20:04:40,678] INFO Closing socket connection to /127.0.0.1. > (kafka.network.Processor) > [ > > > 2014-10-13 20:04:40,678] WARN Error while fetching metadata > [{TopicMetadata for topic test -> > No partition metadata for topic test due to > kafka.common.LeaderNotAvailableException}] for topic [test]: class > kafka.common.LeaderNotAvailableException > (kafka.producer.BrokerPartitionInfo) > [2014-10-13 20:04:40,679] ERROR Failed to collate messages by topic, > partition due to: Failed to fetch topic metadata for topic: test > (kafka.producer.async.DefaultEventHandler) >
