2025年kafka服务端重置LAG、OFFEST规避指南

科技前沿 • 2025-02-17 09:06 • 阅读 43

kafka服务端重置LAG、OFFEST规避指南1 重置 offest LAG 先 kill 停掉业务微服务 2 查询当前消费者组的 LAG 值 client id 这列为才可以执行重置命令 sh kafka consumer groups sh bootstrap server command config config consumer properties

大家好，我是讯享网，很高兴认识大家。

1、重置offest、LAG: 先kill 停掉业务微服务

2、查询当前消费者组的LAG值，client id这列为‘-’，才可以执行重置命令

 sh kafka-consumer-groups.sh --bootstrap-server --command-config ../config/consumer.properties --describe --group clusterBackup-consumer-group

讯享网

在这里插入图片描述
讯享网

3、执行重置offest为未消费状态

讯享网 sh kafka-consumer-groups.sh --bootstrap-server * --group clusterBackup-consumer-group --command-config ../config/consumer.properties --reset-offsets --to-offset 0 --all-topics --execute

在这里插入图片描述

4、执行完再次查询消费者组，状态变为未消费，可以作为消息丢失未消费规避

在这里插入图片描述

5、执行LAG重置为0的操作

sh kafka-consumer-groups.sh --bootstrap-server --group clusterBackup-consumer-group --command-config ../config/consumer.properties --reset-offsets --to-latest --all-topics --execute

在这里插入图片描述