我在使用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来确认这些组的存在和正常工作(使用来自不同主题的消息)。我尝试过直接在命令中放置字符串,而不是使用环境变量。
为什么会出现这个错误?我还能做些什么来调试?
暂无答案!
目前还没有任何答案,快来回答吧!