From 52d0222d63182aca7b024dfb2cb9ebc35a786055 Mon Sep 17 00:00:00 2001 From: Hily Date: Thu, 12 May 2022 09:58:05 +0000 Subject: [PATCH] update study-notes/kafka/kafka.md. --- study-notes/kafka/kafka.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/study-notes/kafka/kafka.md b/study-notes/kafka/kafka.md index bf189fa..675169f 100644 --- a/study-notes/kafka/kafka.md +++ b/study-notes/kafka/kafka.md @@ -1,5 +1,5 @@ # -# 消息队列的流派 +# 消息队列的流派. ### 什么是 MQ @@ -710,7 +710,7 @@ public void listenGroup(ConsumerRecord record,Acknowledgment ack 在触发rebalance机制之前,消费者消费哪个分区有三种策略: -* range:通过公示来计算某个消费者消费哪个分区 +* range:通过公示来计算某个消费者消费哪个分区(n = 分区总数/消费组里的消费者数,m=分区总数%消费组里的消费者数, 前m个消费者消费n+1个分区,剩余的消费者消费n个) * 轮询:大家轮着消费 * sticky:在触发了rebalance后,在消费者消费的原分区不变的基础上进行调整。 -- Gitee