This is what I get -
bin/kafka-topics.sh --zookeeper localhost:2181 --describe
Topic:Heartbeat PartitionCount:2 ReplicationFactor:1 Configs:
Topic: Test Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Topic: Test Partition: 1 Leader: 0 Replicas: 0 Isr: 0
The topics are being created at run-time.
thanks
On Sun, Oct 26, 2014 at 4:49 PM, Guozhang Wang <wangg...@gmail.com> wrote:
> 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
>
