diff --git a/study-notes/kafka/kafka.md b/study-notes/kafka/kafka.md index bf189faa135c1eb13ff6f6d3c099b25100473f9c..675169fe66de771fdec3fd2b4218ae048320855a 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后,在消费者消费的原分区不变的基础上进行调整。