Sameer,

The topic name is not consistent from your describe outputs. Normally they
should be either

 Topic:*Test*    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

Or

 Topic:*Heartbeat*    PartitionCount:2    ReplicationFactor:1    Configs:
    Topic: *Heartbeat*        Partition: 0    Leader: 0    Replicas: 0
Isr: 0
    Topic: *Heartbeat*        Partition: 1    Leader: 0    Replicas: 0
Isr: 0

Did you manually modify the topic name in ZK?

Guozhang

On Tue, Oct 28, 2014 at 8:53 AM, Sameer Yami <sy...@ailive.net> wrote:

> Hi Guozhang,
>
> I was wondering if there is anything wrong in the above --describe data.
>
> thanks
>
>
> On Mon, Oct 27, 2014 at 2:56 PM, Sameer Yami <sy...@ailive.net> wrote:
>
> > 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
> >>
> >
> >
>



-- 
-- Guozhang

Reply via email to