如何使用kafka-consumer-groups.sh

Kafka-consumer-groups.sh 是一个用于管理 Kafka 消费者组的命令行工具。你可以使用它来列出或重置消费者组的偏移量、查看当前偏移量的状态以及获取消费者组的信息。

要使用kafka-consumer-groups.sh，首先需要确保Kafka已经安装并运行。然后，打开终端窗口，并使用以下命令：

./kafka-consumer-groups.sh [options]

其中，options部分包含一系列选项，可用于定义特定的操作。例如，如果要列出消费者组的成员，可以使用以下命令：

./kafka-consumer-groups.sh --list --bootstrap-server localhost:9092

上述命令将列出指定启动服务器的所有消费者组。

如果要查看消费者组中每个成员的当前偏移量，请使用以下命令：

./kafka-consumer-groups.sh --describe --group test-consumer-group --bootstrap-server localhost:9092

上述命令将显示“test-consumer-group”消费者组中每个成员的当前偏移量，以及它们正在消费的主题和分区。

如果要重置消费者组的偏移量，可以使用以下命令：

./kafka-consumer-groups.sh --reset-offsets --group test-consumer-group --to-latest --execute --bootstrap-server localhost:9092

上述命令将重置“test-consumer-group”消费者组的偏移量，以便从最新可用的消息开始消费。