Well i masked my true domain but the hostnames are valid and do work. I do
see the topics creates in ZK
brokers/topics/topic-test-production/partisions/0/state
{"controller_epoch":10,"leader":26665,"version":1,"leader_epoch":2,"isr":[26665]}
brokers/topics/topic-test-production/partisions/1/state
{"controller_epoch":10,"leader":26665,"version":1,"leader_epoch":3,"isr":[26665]}
for example {"version":1,"partitions":{"1":[2028,26665],"0":[26665,2028]}}
But now I do get the below on describe:
roduction PartitionCount:2 ReplicationFactor:2 Configs:
Topic: topic-test-production Partition: 0 Leader: 26665 Replicas:
26665,2028 Isr:
26665
Topic: topic-test-production Partition: 1 Leader: 26665 Replicas:
2028,26665 Isr:
26665
But in kafka-python I still get this error
kafka.common.LeaderNotAvailableError:
TopicMetadata(topic='topic-test-production', error=5, partitions=[])
On Fri, Oct 9, 2015 at 5:31 PM, Prabhjot Bharaj <prabhbha...@gmail.com>
wrote:
> Hi,
>
> Is this a valid zookeeper connection string
>
>
> 1.zk.do.production.test:2181,2.zk.do.production.test:2181,3.zk.do.production.test:2181
>
> Is 2.zk.do.production.test or 3.zk.do.production.test a valid hostname??
>
> Regards,
> Prabhjot
> On Oct 9, 2015 1:37 PM, "David Montgomery" <davidmontgom...@gmail.com>
> wrote:
>
> > PS I added one more server now 3 kafka servers. still kafka is not
> > working. Is there a known bug?
> >
> > On Fri, Oct 9, 2015 at 3:23 PM, David Montgomery <
> > davidmontgom...@gmail.com>
> > wrote:
> >
> > > i,
> > >
> > > I have 3 ZK servers and 2 kafka servers with 2 partitions.
> > >
> > > I am using kafka_2.11-0.8.2.1
> > >
> > > Here is how I am creating a topic:
> > >
> > > bin/kafka-topics.sh --zookeeper
> > >
> >
> 1.zk.do.production.test:2181,2.zk.do.production.test:2181,3.zk.do.production.test:2181
> > > --create --topic topic-test-production --partitions 2
> > --replication-factor 2
> > >
> > > here is what I describe:
> > >
> > > bin/kafka-topics.sh
> > > --zookeeper
> >
> .zk.do.production.test:2181,2.zk.do.production.test:2181,3.zk.do.production.test:2181
> > --describe
> > > --topic topic-test-production
> > >
> > > Topic:topic-test-production PartitionCount:2 ReplicationFactor:2
> Configs:
> > > Topic: topic-test-production Partition: 0 Leader: none Replicas:
> > > 26665,2028 Isr:
> > > Topic: topic-test-production Partition: 1 Leader: none Replicas:
> > > 2028,26665 Isr:
> > >
> > > When i try to write to kafka in python I get this error.
> > >
> > > kafka.common.LeaderNotAvailableError:
> > > TopicMetadata(topic='topic-test-production', error=5, partitions=[])
> > >
> > > What is wrong with kafka?
> > >
> > > Thanks
> > >
> > >
> > >
> > >
> > >
> > >
> >
>
