Re: Not able to connect to bootstrap server when one broker down

What error you are getting , can you share the exact error ? What is version of kafka lib at client side ? On 8/25/20, 7:50 AM, "Prateek Rajput" wrote: [External] Hi, please if anyone can help, will be a huge favor. *Regards,* *Prateek Rajput* On Tue, Aug 25, 2020 at

Python error after upgrading confluent-kafka library

I upgraded confluent-kafka from 1.0.1 to 1.4.2. After upgrading, if I execute 'pip install' I am getting the following error. I am using python 2.7. Has anyone else encountered this issue? Traceback (most recent call last):import confluent_kafka as kafkaFile "/home/sshil/virtual_envs/ma_venv/local

Re: Not able to connect to bootstrap server when one broker down

Hi Rohit, We checked that ISR was available and all leaders were there. It was failing during instantiation of the client, while making the very first connection to a broker. Because randomly it selected only that broker from *bootstrap.servers *list which was down and tried to connect to that serv

Re: Not able to connect to bootstrap server when one broker down

Please check your ISR using describe command and see if there is leader available when one of the broker is down . Thanks and Regards, Rohit On Tue, Aug 25, 2020, 20:20 Prateek Rajput wrote: > Hi, please if anyone can help, will be a huge favor. > > *Regards,* > *Prateek Rajput* > > > On Tue,

Re: Not able to connect to bootstrap server when one broker down

Hi, please if anyone can help, will be a huge favor. *Regards,* *Prateek Rajput* On Tue, Aug 25, 2020 at 12:06 AM Prateek Rajput wrote: > Hi everyone, > I am new to Kafka, and recently started working on kafka in my company. We > recently migrated our client and cluster from the *0.10.x* vers

Re: Request to be Assignee on JIRA

Thanks! On 2020/08/24 14:04:56, Bill Bejeck wrote: > Done. Thanks for your interest in Apache Kafka. > > -Bill > > On Mon, Aug 24, 2020 at 8:34 AM xaka...@mail.ru.INVALID > wrote: > > > Hi, guys! I'd like to provide a PR for KAFKA-10426. But I'm not in the > > Assignee list. Could you, plea

Re: Consumer Group rebalancing events

Hi, Srinivas Devaki ! There are Kafka JMX metrics - NumGroupsCompletingRebalance and NumGroupsPreparingRebalance. I think you can monitor them by some application and calculate statistic. As for us - we added Jolokia agent to our Kafka docker image and Jolokia expose all JMX metrics via HTTP.

Re: Request to be Assignee on JIRA

Already added, thanks. On 2020/08/24 11:57:18, "xaka...@mail.ru.INVALID" wrote: > Hi, guys! I'd like to provide a PR for KAFKA-10426. But I'm not in the > Assignee list. Could you, please, add me? > But I'm not sure that I'm writing to the right mailing list. > My JIRA full name is Goltseva Ta

Topic Partition Admin operation

Hello, I tried to find this information, but may be I searched for the wrong stuff. I am trying to identify what's the last message written on a TopicPartition. My constraints are: 1) No Knowledge of the last offset - so I cannot use seek(TopicPartition, long) 2) I have to retrieve the last-writ

Re: Consumer Group rebalancing events

 Hi,  Srinivas Devaki! There are Kafka JMX metrics - NumGroupsCompletingRebalance and NumGroupsPreparingRebalance. I think you can monitor them by some application and calculate statistic. As for us - we added Jolokia agent to our Kafka docker image and Jolokia expose all JMX metrics via HHTP.