kafka producer 發送消息的流程分析

爲什麼80%的碼農都做不了架構師？>>>    producer 是如何將某個topic的一條record發送到該topic對應的某個分區Partition上面去的？ 首先分析一個重要的消息載體  ConcurrentMap<TopicPartition, Deque<RecordBatch>> 的結構，它是一個Map(對HashMap進行了包裝，HashMap不是線程安全的，而其包裝類CopyO

>>阅读原文<<