标签频道
offset提交
该标签下的文章、提问与讨论帖。
背景 我带团队跑一条履约事件流:Kafka 3.5(KRaft,3 broker),topic "fulfill-event" 16 分区,消费组 8 实例(K8s Deployment)。消费端为了吞吐做了攒批:"max.poll.rec
背景 我负责一条订单履约链路:Kafka 3.5(3 broker KRaft),topic "order-fulfill" 16 分区,消费组 6 实例(K8s Deployment,maxSurge=1 / maxUnavailable
背景 Kafka 3.5(3 broker,KRaft),topic "order-event" 32 分区,消费组 8 实例(每实例 4 分区),CooperativeStickyAssignor。 关键配置:"max.poll.reco
背景 - Kafka 3.4(3 broker KRaft),topic "order-pay" 32 分区,消费组 12 实例(K8s Deployment,maxSurge=1 / maxUnavailable=0),日均约 4500
【背景】 我们用 Kafka 3.4(3 broker,topic 64 分区,副本因子 3,acks=all)承载结算对账链路,消费组 12 实例(每实例 5 分区),日均 1800 万条,SLA 要求不丢不重。下游是 MySQL 8.0
【背景】 订单结算服务,Kafka 3.5(3 broker,ISR=3),topic "settle-bill" 12 分区,消费组 6 实例,"max.poll.records=200"。单条消费逻辑是「校验 → 写 MySQL 8.0
【背景】 我们用 Kafka 3.5(3 broker)消费一条库存扣减链路:topic "stock-deduct" 16 分区,消费组 8 实例,"max.poll.records=500"。消费逻辑是「读 batch → 逐条扣减 M
文
标题
摘要