更换Kafka消费者为Kafka Streams后，如何处理旧消费者偏移量遗留问题？

你无需删除整个消费组，只需清除该消费组针对目标Topic的位移记录即可，具体操作如下：

1. 确认当前位移状态 #

先用Kafka自带的消费者组工具，查看目标消费组和Topic的位移详情，确认堆积情况：

kafka-consumer-groups.sh --bootstrap-server <你的Kafka集群地址> --describe --group <你的消费组名称> --topic <原消费者处理的Topic名>

执行后会显示该Topic各分区的当前消费位移（CURRENT-OFFSET）、最新位移（LOG-END-OFFSET）以及落后的消息数（LAG）。

2. 重置目标Topic的位移到最新位置 #

直接将该消费组下目标Topic的所有分区位移重置为当前最新消息的位置，这样Kafka就会认为原消费者已消费完所有消息，不再显示堆积：

kafka-consumer-groups.sh --bootstrap-server <你的Kafka集群地址> --reset-offsets --to-latest --group <你的消费组名称> --topic <原消费者处理的Topic名> --execute

注意：执行此命令前，必须确保该消费组下没有任何活跃消费者在订阅这个目标Topic（你已停用原消费者，此条件满足），避免干扰正常运行的消费者。

3. 验证结果 #

再次执行第一步的describe命令，查看LAG是否变为0，Kafka管理UI中的堆积提示也会同步消失。

若你的Kafka版本低于2.4.0，--to-latest参数可替换为--to-current，具体可通过kafka-consumer-groups.sh --help查看对应版本的参数说明。

内容的提问来源于stack exchange，提问作者wolle