Re: kafka cluster question

2024-01-22 Thread Yavuz Sert
Hi, As Artem mentioned, I did some tests with setting replication factor 1 and 3 for two different topics One of the kafka broker is down: The command works if the replication factor is 3. (*testtopicreplica3 is created with rf 3)* *[root@node-223 kafka_2.12-2.8.2]# ./bin/kafka-consumer-gr

Re: kafka cluster question

2024-01-20 Thread Artem Timchenko
Hi, Just a long shoot, but I might be wrong. You have offsets.topic.replication.factor=1 in you config, when one broker is down, some partitions of __consumer_offsets topic will be down either. So kafka-consumer-groups can't get offsets from it. Maybe it's just a little misleading error message.

Re: kafka cluster question

2024-01-20 Thread Yavuz Sert
Hi, sorry for the confusion, here is details: I have 3 broker nodes: 192.168.20.223 / 224 / 225 When all kafka services are UP: [image: image.png] I stopped the kafka service on *node 225*: [image: image.png] Then i tried the command on node223 with --bootstrap-server 192.168.20.223:9092,192.16

Re: kafka cluster question

2024-01-19 Thread Haruki Okada
Hi. Which server did you shutdown in testing? If it was 192.168.20.223, that is natural kafka-consumer-groups script fails because you passed only 192.168.20.223 to the bootstrap-server arg. In HA setup, you have to pass multiple brokers (as the comma separated string) to bootstrap-server so that

kafka cluster question

2024-01-19 Thread Yavuz Sert
Hi all, I'm trying to do some tests about high availability on kafka v2.8.2 I have 3 kafka brokers and 3 zookeeper instances. when i shutdown one of the kafka service only in one server i got this error: [root@node-223 ~]# /root/kafka_2.12-2.8.2/bin/kafka-consumer-groups.sh --bootstrap-server 192