硅基社区
标签频道

数据补偿

该标签下的文章、提问与讨论帖。

问 Kafka 消费端按时间戳重放历史消息做数据补偿,如何与实时消费并行且不重复不丢失
【背景】 我做订单履约服务,Kafka 3.5(3 节点),topic "order-fulfill" 16 分区,实时消费组 8 实例,日均约 4000 万条,消费逻辑是「读 batch → 写 MySQL 8.0 → 提交 offset