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
>
