查看kafka消费组时报错

问题描述

执行kafka 脚本 ,

kafka-consumer-groups.sh --bootstrap-server controller-server-host:9092 --list

无法看查看消费组，以下是error info:

org.apache.kafka.common.errors.DisconnectException: Cancelled
fetchMetadata request with correlation id 71 due to node -3 being
disconnected

Error: Executing consumer group command failed due to
org.apache.kafka.common.KafkaException: Failed to find brokers to send
ListGroups java.util.concurrent.ExecutionException:
org.apache.kafka.common.KafkaException: Failed to find brokers to send
ListGroups
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.inter

解决

vi consume-group-ssl.properties

security.protocol=SASL_PLAINTEXT
sasl.mechanism=GSSAPI
sasl.kerberos.service.name=kafka

在kafka-consumer-groups.sh 脚本运行时，添加参数： --command-config …/config/client-ssl.properties， 即可。