From 4666687ff375927c80d0a95f60fe1e8deebad5a0 Mon Sep 17 00:00:00 2001 From: sid <673088860@qq.com> Date: Sun, 5 Jan 2020 15:59:21 +0800 Subject: [PATCH] =?UTF-8?q?Dueue=E5=BA=94=E8=AF=A5=E6=94=B9=E6=88=90Deque?= =?UTF-8?q?=EF=BC=8C=E5=8F=8C=E7=AB=AF=E9=98=9F=E5=88=97=E7=9A=84=E6=84=8F?= =?UTF-8?q?=E6=80=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Kafka系统设计开篇-面试看这篇就够了.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/system-design/data-communication/Kafka系统设计开篇-面试看这篇就够了.md b/docs/system-design/data-communication/Kafka系统设计开篇-面试看这篇就够了.md index e617c3b3..d21fad3a 100644 --- a/docs/system-design/data-communication/Kafka系统设计开篇-面试看这篇就够了.md +++ b/docs/system-design/data-communication/Kafka系统设计开篇-面试看这篇就够了.md @@ -50,7 +50,7 @@ Consumer Group：同一个Consumer Group中的Consumers，Kafka将相应Topic中 ProducerRecord对象中如果指定了partition，就使用这个partition。否则根据key和topic的partition数目取余，如果key也没有的话就随机生成一个counter，使用这个counter来和partition数目取余。这个counter每次使用的时候递增。 **2发送到batch&&唤醒Sender 线程** -根据topic-partition获取对应的batchs（Dueue），然后将消息append到batch中.如果有batch满了则唤醒Sender 线程。队列的操作是加锁执行，所以batch内消息时有序的。后续的Sender操作当前方法异步操作。 +根据topic-partition获取对应的batchs（Deque），然后将消息append到batch中.如果有batch满了则唤醒Sender 线程。队列的操作是加锁执行，所以batch内消息时有序的。后续的Sender操作当前方法异步操作。 ![send_msg](https://blog-article-resource.oss-cn-beijing.aliyuncs.com/kafka/send2Batch1.png)![send_msg2](https://blog-article-resource.oss-cn-beijing.aliyuncs.com/kafka/send2Batch2.png)