kafka producer 发送消息的流程分析

为什么80%的码农都做不了架构师？>>>    producer 是如何将某个topic的一条record发送到该topic对应的某个分区Partition上面去的？ 首先分析一个重要的消息载体  ConcurrentMap<TopicPartition, Deque<RecordBatch>> 的结构，它是一个Map(对HashMap进行了包装，HashMap不是线程安全的，而其包装类CopyO

>>阅读原文<<