1

你搜关键词 offset management ，不是一句两句能说清的。
一个简单粗暴的方法就是关闭 auto commit ，然后在 loop 里计数，每处理 x 个 message 后 commit 一下。
x 越小 commit 次数越多，overhead 大，重复处理或者 skip 掉的 message 就越少。
x 越大 commit 次数越少，overhead 小，但是可能需要重复处理的 message 更多，各种 tradeoff 要考虑。