将kafka 消费组offset置为最新
时间: 2023-10-18 13:25:01 浏览: 46
要将 Kafka 消费组的 offset 置为最新,可以使用 Kafka 提供的命令行工具 kafka-consumer-groups.sh,具体操作步骤如下:
1. 执行以下命令,将消费组的 offset 置为最新:
```
kafka-consumer-groups.sh --bootstrap-server <kafka_broker_host>:<kafka_broker_port> --group <consumer_group_name> --reset-offsets --to-latest --execute
```
其中,<kafka_broker_host> 和 <kafka_broker_port> 分别是 Kafka Broker 的主机名和端口号,<consumer_group_name> 是要置为最新 offset 的消费组的名称。
2. 执行成功后,可以使用以下命令验证 offset 是否已经置为最新:
```
kafka-consumer-groups.sh --bootstrap-server <kafka_broker_host>:<kafka_broker_port> --group <consumer_group_name> --describe
```
其中,<kafka_broker_host> 和 <kafka_broker_port> 分别是 Kafka Broker 的主机名和端口号,<consumer_group_name> 是要查询的消费组的名称。如果输出结果中“CURRENT-OFFSET”和“LOG-END-OFFSET”相等,说明 offset 已经被置为最新。