It's not hanging. The console producer shell script allows you to enter message via the console. So when you execute it, it waits for your console input.
Also, the kafka distribution is missing a couple jar files: slf4j-nop-1.7.2.jar mx4j-tools.jar You can google them and find them online. On Tue, Oct 14, 2014 at 10:13 AM, Mohit Anchlia <mohitanch...@gmail.com> wrote: > 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) > > > -- Bowei
