使用bin/kafka-consumer-groups.sh --bootstrap-server * --describe --group *查询消费组信息时，报错

落忧发表于: 2019-07-22 最后更新时间: 2019-07-22 18:27:40 4,152 游览

报空指针异常

kafka

发表于 2019-07-22

落忧

添加评论

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
kafka什么版本。

回答于 4年前

半兽人

野心永恒 -> 半兽人 4年前

你好，我使用的kafka版本是：kafka_2.11-2.0.1
使用bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
查询报：
Exception in thread "main" joptsimple.UnrecognizedOptionException: new-consumer is not a recognized option
at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)
at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)
at joptsimple.OptionParser.parse(OptionParser.java:396)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupCommandOptions.(ConsumerGroupCommand.scala:725)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:42)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
这个异常

半兽人 -> 野心永恒 4年前

把 --new-consumer 这个去掉在执行下。

落忧 -> 半兽人 4年前

0.10.0.1，我现在的问题是kafka消费一段时间后，无法消费到数据，需要换一个groupid才行，但是之后又会遇到相同问题

半兽人 -> 落忧 4年前

这么神奇。你用命令形式还是程序的？
https://www.orchome.com/451
用官方的例子跑，不要改动任何东西。

你的答案

查看kafka相关的其他问题或提一个您自己的问题。

提问

找不到想要的答案？提一个您自己的问题。

使用bin/kafka-consumer-groups.sh --bootstrap-server * --describe --group *查询消费组信息时，报错

你的答案

昵称