In bootstrap server put at least two brokers nodes of the cluster to get the metadata of the initial connection
בתאריך יום ב׳, 17 במאי 2021, 18:07, מאת Aniket Pant <pantanik...@gmail.com >: > Hi team, > my question is , i have 3 nodes of kafka cluster and when i stop one broker > i cannot lag messages it show me error like > ``` > [2021-05-17 19:20:22,583] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > [2021-05-17 19:20:22,685] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > [2021-05-17 19:20:22,887] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > [2021-05-17 19:20:23,189] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > [2021-05-17 19:20:23,692] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > [2021-05-17 19:20:24,395] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > [2021-05-17 19:20:25,499] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > [2021-05-17 19:20:26,704] WARN [AdminClient clientId=adminclient-1] > Connection to node -1 (localhost/xx.xx.xx.xx:9092) could not be > established. Broker may not be available. > (org.apache.kafka.clients.NetworkClient) > Error: Executing consumer group command failed due to > org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a > node assignment. > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a > node assignment. > at > > org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45) > at > > org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32) > at > > org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89) > at > > org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260) > at > > kafka.admin.ConsumerGroupCommand$ConsumerGroupService.collectGroupOffsets(ConsumerGroupCommand.scala:331) > at > > kafka.admin.ConsumerGroupCommand$ConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:251) > at > kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:59) > at > kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) > Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out > waiting for a node assignment. > ``` > I was running `bin/kafka-consumer-groups.sh --describe --group pfsense_user > --all-topics --bootstrap-server xx.xx.xx.xx:9092' >
