Kafka在发送一条消息时经历了什么？

Kafka在发送一条消息到borker以前，须要通过过滤器，序列化器， 分区器。 整个生产者客户端由两个线程协调运行,这两个线程分别为主线程 和 Sender线程 。在主线程中由 KafkaProducer建立消息,而后经过可能的拦截器、序列化器和分区器的做用以后缓存到RecordAccumulator中 Sender 线程负责从 RecordAccumulator中获取消息并将其发送到 Kafk

>>阅读原文<<