Could you use the topic tools "--describe" to check if the topic Test's partitions leaders are available?
http://kafka.apache.org/documentation.html#basic_ops_add_topic Guozhang On Fri, Oct 24, 2014 at 2:43 PM, Sameer Yami <sy...@ailive.net> wrote: > That is not the case. > This detailed error is below. Due to this error , the producer is not able > to send messages > > 2014-10-24 14:31:47,209 main DEBUG kafka.producer.BrokerPartitionInfo-52: > Getting broker partition info for topic Test > 2014-10-24 14:31:47,209 main INFO kafka.client.ClientUtils$-68: Fetching > metadata from broker id:0,host:54.215.200.61,port:9092 with correlation id > 1 for 1 topic(s) Set(Test) > 2014-10-24 14:31:47,230 main DEBUG kafka.network.BlockingChannel-52: > Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = > 187200 (requested -1), SO_SNDBUF = 102400 (requested 102400). > 2014-10-24 14:31:47,231 main INFO kafka.producer.SyncProducer-68: > Connected to 54.215.200.61:9092 for producing > 2014-10-24 14:31:47,256 main INFO kafka.producer.SyncProducer-68: > Disconnecting from 54.215.200.61:9092 > 2014-10-24 14:31:47,256 main DEBUG kafka.client.ClientUtils$-52: > Successfully fetched metadata for 1 topic(s) Set(Test) > 2014-10-24 14:31:47,257 main WARN kafka.producer.BrokerPartitionInfo-83: > 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 > 2014-10-24 14:31:47,258 main ERROR > kafka.producer.async.DefaultEventHandler-97: Failed to collate messages by > topic, partition due to: Failed to fetch topic metadata for topic: Test > > On Fri, Oct 24, 2014 at 1:11 PM, Guozhang Wang <wangg...@gmail.com> wrote: > > > Could you see if this is the case: > > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whycan%27tmyconsumers/producersconnecttothebrokers > > ? > > > > On Fri, Oct 24, 2014 at 11:35 AM, Sameer Yami <sy...@ailive.net> wrote: > > > > > Hi, > > > > > > We have a Kafka / Zookeeper test setup on a single EC2 machine. The > > > host.name is the private ip address and the advertised.host.name is > the > > > public address in server.properties. > > > > > > We are trying to publish from outside EC2 using the public ip of the > EC2 > > > machine but get this error on the client side - > > > No partition metadata for topic test due to > > > kafka.common.LeaderNotAvailableException}] for topic [test]: class > > > kafka.common.LeaderNotAvailableException > > > > > > The zookeeper has the public ip stored in /brokers/ids/0. > > > We have tried multiple combinations but it works ONLY when the > advertised > > > host name is not used and the client is internal to EC2. > > > > > > Please let me know what the problem could be. > > > > > > thanks > > > Sameer > > > > > > > > > > > -- > > -- Guozhang > > > -- -- Guozhang
