























这是一个创建于 1783 天前的主题,其中的信息可能已经有所发展或是发生改变。
rt,我这边遇到个问题,需要 kafka 多线程消费数据。
已知同一个 groupid,能控制多个消费者竞争问题,不会出现同一条数据被多个消费者重复读取。
但是多个线程同时去读,是否必须手动提交 offset,auto_commit 不知道能否满足要求?
我在网上看到的 case,基本上是让本地建个临时 sqlite 库,根据 partion 和线程对应去消费,手动提交 offset 。
比如:https://www.cnblogs.com/lshan/p/11647485.html
我不知道最佳实践是怎样的?
各位大佬,很急在线等!
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。