kafka-consumer-groups 命令问题答案

【问题标题】：kafka-consumer-groups command issuekafka-consumer-groups 命令问题
【发布时间】：2019-12-29 21:06:27
【问题描述】：

我运行这个命令：

kafka-consumer-groups --bootstrap-server localhost:9092 --group my-consumer-group --reset-offsets --to-earliest --execute --topic my-topic-1

报错：

命令的语法不正确。

根据此命令的帮助结果，我输入的内容似乎是正确的。

我在这里犯了什么错误？

【问题讨论】：

【解决方案1】：

编辑：根据documentation 示例，在为消费者组重置偏移量时，似乎不需要--execute。

EDIT2：我已经查看了source code，显然需要--execute，否则它将被视为空运行，因此不会重置偏移量。如果您的二进制文件是在此 fix 之前构建的，那么您将收到上述无效命令错误。

删除它，您的命令将起作用：

kafka-consumer-groups --bootstrap-server localhost:9092 --group my-consumer-group --reset-offsets --to-earliest --topic my-topic-1

【讨论】：

您应该链接到某个特定版本（标签）。根据文档选项--execute，需要to execute --reset-offsets process.
是的，--execute 是重置偏移量所必需的，否则就像我上面提到的那样，它将被视为空运行。这适用于所有支持-reset-offsets标志的Kafka版本。