This is the python error
kafka.common.LeaderNotAvailableError:
TopicMetadata(topic='topic-test-production', error=5, partitions=[])
On Fri, Oct 9, 2015 at 6:55 PM, David Montgomery <davidmontgom...@gmail.com>
wrote:
> 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
>> > >
>> > >
>> > >
>> > >
>> > >
>> > >
>> >
>>
>
>
