你好,我使用的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) 这个异常
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
kafka什么版本。
你好,我使用的kafka版本是:kafka_2.11-2.0.1(ConsumerGroupCommand.scala:725)
使用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.
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:42)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
这个异常
把 --new-consumer 这个去掉在执行下。
0.10.0.1,我现在的问题是kafka消费一段时间后,无法消费到数据,需要换一个groupid才行,但是之后又会遇到相同问题
这么神奇。你用命令形式还是程序的?
https://www.orchome.com/451
用官方的例子跑,不要改动任何东西。
你的答案