如何在保留Group ID且已有Offset时从最大Offset消费Kafka并丢弃旧消息？

首先要划重点：你提到的auto.offset.reset配置只在两种场景下生效——一是该Group没有初始偏移量记录时，二是已有的偏移量超出了当前Topic的可用消息范围时。所以当Group已经存在有效偏移量时，这个配置不会帮你丢弃旧消息，得用下面的方法：

• 首选方案：重置Group偏移量到最新位置
  直接用问题1里的命令行工具方法，执行偏移量重置操作。这样既保留了原有的Group ID，又让consumer下次启动时直接从最新消息开始，相当于自动丢弃了之前未消费的旧消息。

• 代码层面临时调整
  如果你不想修改Kafka存储的偏移量，也可以在consumer代码里加入手动定位到最新位置的逻辑（就是问题1里的方法二）。这样每次启动consumer都会跳过旧消息，只消费新产生的内容；如果之后想恢复正常消费，去掉这段seek逻辑即可。

• 谨慎操作：删除Group的偏移量记录
  也可以先删除该Group的偏移量存储，这样下次consumer启动时，因为没有初始偏移量，就会触发auto.offset.reset=latest的逻辑（前提是你已经把这个配置设为latest）：

  kafka-consumer-groups.sh --bootstrap-server <你的Kafka集群地址> --group <你的Group ID> --delete
  

  注意：这个操作会彻底删除该Group的所有历史偏移量记录，之后无法恢复之前的消费位置，一定要谨慎使用。

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