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

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

报空指针异常

发表于 2019-07-22
添加评论

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

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

你好,我使用的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)
这个异常

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

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

落忧 -> 半兽人 5年前

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

半兽人 -> 落忧 5年前

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

你的答案

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