consumer-groups.sh获取kafka消费者延迟时出错

blmhpbnm  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(234)

我在使用kafka命令行工具获取给定组/主题的使用者延迟时遇到了问题。目前,我正在尝试使用 kafka-consumer-groups.sh 正如无数在线资源中提到的。以下命令工作正常: kafka-consumer-groups.sh --bootstrap-server $BROKERS --list 但是,如果我使用 kafka-consumer-groups.sh --bootstrap-server $BROKERS --describe --group $GROUP ,我得到以下输出和错误:

Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).

[2018-07-24 00:19:09,139] ERROR admin-client-network-thread exited (kafka.admin.AdminClient) java.lang.NullPointerException
        at org.apache.kafka.common.utils.Utils.join(Utils.java:399)
        at org.apache.kafka.common.requests.OffsetFetchRequest$Builder.toString(OffsetFetchRequest.java:74)
        at java.lang.String.valueOf(String.java:2994)
        at java.lang.StringBuilder.append(StringBuilder.java:131)
        at org.apache.kafka.clients.ClientRequest.toString(ClientRequest.java:63)
        at org.apache.kafka.clients.NetworkClient.doSend(NetworkClient.java:374)
        at org.apache.kafka.clients.NetworkClient.send(NetworkClient.java:332)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.trySend(ConsumerNetworkClient.java:409)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:252)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:208)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:199)
        at kafka.admin.AdminClient$$anon$1.run(AdminClient.scala:61)
        at java.lang.Thread.run(Thread.java:748) Error: Executing consumer group command failed due to The server experienced an unexpected error when processing the request

我试过设置 GROUP 我用kafkatool来确认这些组的存在和正常工作(使用来自不同主题的消息)。我尝试过直接在命令中放置字符串,而不是使用环境变量。
为什么会出现这个错误?我还能做些什么来调试?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题