V2EX = way to explore V2EX 是一个关于分享和探索的地方
Sign Up Now For Existing Member Sign In
This topic created in 1291 days ago, the information mentioned may be changed or developed.
比如 poll 了 1000 条内容，已经消费了 500 个，此时要中断消费，那么剩余的 500 个岂不是丢了，如何保证消费完再退出？监听信号量吗？
 | 1 andrewpsy Oct 18, 2022 你搜关键词 offset management ，不是一句两句能说清的。 一个简单粗暴的方法就是关闭 auto commit ，然后在 loop 里计数，每处理 x 个 message 后 commit 一下。 x 越小 commit 次数越多，overhead 大，重复处理或者 skip 掉的 message 就越少。 x 越大 commit 次数越少，overhead 小，但是可能需要重复处理的 message 更多，各种 tradeoff 要考虑。 |
 | 2 daoqiongsi1101 OP @andrewpsy 你说的是提交 offset 的方式，自动提交，手动提交，自动手动结合，还有位移提交。我说的是取出来的消息，没消费完如何优雅中止 |
Select Language