温馨提示:本文基于 Kafka 2.2.1 版本。如果觉得源码阅读比较枯燥,本文的中间有 Sender 线程的工作流程图。
上文 已经详细介绍了 KafkaProducer send 方法的流程,该方法只是将消息追加到 KafKaPr
2021-04-05