I ran it again but it seems to be hanging:
[2014-10-13 20:43:36,341] INFO Closing socket connection to /10.231.154.117. (kafka.network.Processor) [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:43:59,397] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor) On Mon, Oct 13, 2014 at 5:29 PM, Jun Rao <jun...@gmail.com> wrote: > Is that error transient or persistent? > > Thanks, > > Jun > > 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) > > >
