You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Aniket Pant <pa...@gmail.com> on 2021/05/17 13:57:42 UTC
kafka command is not working
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'
Re: kafka command is not working
Posted by Ran Lupovich <ra...@gmail.com>.
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 <pantaniket1@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'
>