Kafka生产者客户端中使用了几个线程来处理？分别是什么？
发布于 2020-05-19 18:13:17
关注者
0
被浏览
587
1 个回答
-
2个，
主线程和Sender线程。主线程负责创建消息，然后通过分区器、序列化器、拦截器作用之后缓存到累加器RecordAccumulator中。
Sender线程负责将RecordAccumulator中消息发送到kafka中.
#
