Error while getting consumer lag managed kafka cluster

Confluent61 — Mon, 20 Mar 2023 19:57:06 GMT

[2023-03-20 17:43:00,250] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

./kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group topicname

we are using security.inter.broker.protocol=SSL

Getting below error

Error: Executing consumer group command failed due to org.apache.kafka.common.errors.TimeoutException: Call(callName=findCoordinator, deadlineMs=1679341973470, tries=1, nextAllowedTryMs=1679341973571) timed out at 1679341973471 after 1 attempt(s)
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Call(callName=findCoordinator, deadlineMs=1679341973470, tries=1, nextAllowedTryMs=1679341973571) timed out at 1679341973471 after 1 attempt(s)
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.$anonfun$describeConsumerGroups$1(ConsumerGroupCommand.scala:551)
at scala.collection.StrictOptimizedMapOps.map(StrictOptimizedMapOps.scala:28)
at scala.collection.StrictOptimizedMapOps.map$(StrictOptimizedMapOps.scala:27)
at scala.collection.convert.JavaCollectionWrappers$AbstractJMapWrapper.map(JavaCollectionWrappers.scala:309)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.describeConsumerGroups(ConsumerGroupCommand.scala:550)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.collectGroupsOffsets(ConsumerGroupCommand.scala:567)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.describeGroups(ConsumerGroupCommand.scala:369)
at kafka.admin.ConsumerGroupCommand$.run(ConsumerGroupCommand.scala:76)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:63)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
Caused by: org.apache.kafka.common.errors.TimeoutException: Call(callName=findCoordinator, deadlineMs=1679341973470, tries=1, nextAllowedTryMs=1679341973571) timed out at 1679341973471 after 1 attempt(s)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: findCoordinator

Re: Error while getting consumer lag managed kafka cluster

DianaTorres — Tue, 21 Mar 2023 00:23:34 GMT

@Confluent61 Welcome to the Cloudera Community!

To help you get the best possible solution, I have tagged our Kafka experts @paras and @rki_ who may be able to assist you further.

Please keep us updated on your post, and we hope you find a satisfactory solution to your query.

question Error while getting consumer lag managed kafka cluster in Support Questions

Error while getting consumer lag managed kafka cluster

Re: Error while getting consumer lag managed kafka cluster