Exception in thread "main" joptsimple.UnrecognizedOptionException: create is not a recognized option
时间: 2023-10-24 17:00:25 浏览: 199
config.sub Invalid configuration machine/OS not recognized问题解决
抱歉给您带来困扰。根据您提供的错误信息,看起来您使用的kafka-consumer-groups.sh命令中包含了不被识别的选项"create"。这可能是因为您使用的Kafka版本不支持该选项或者该选项被更改了。
请确保您使用的是与您Kafka版本相匹配的kafka-consumer-groups.sh命令,并使用正确的选项。不同版本的Kafka可能会有略微不同的命令和选项。
另外,您可以尝试使用`--describe`选项来查看已经存在的消费组,或者使用`--reset-offsets`选项来重置消费组的偏移量。例如:
```
kafka-consumer-groups.sh --bootstrap-server <your-bootstrap-server> --command-config <path-to-consumer-config> --describe --group <your-group-name>
```
```
kafka-consumer-groups.sh --bootstrap-server <your-bootstrap-server> --command-config <path-to-consumer-config> --reset-offsets --group <your-group-name> --to-earliest --execute --topic <your-topic>
```
请确保替换命令中的占位符`<your-bootstrap-server>`、`<path-to-consumer-config>`、`<your-group-name>`和`<your-topic>`为正确的值。
如果问题仍然存在,请提供您所使用的Kafka版本和完整的命令,以便我们更好地帮助您解决问题。谢谢!
阅读全文