2个，
主线程和Sender线程。主线程负责创建消息，然后通过分区器、序列化器、拦截器作用之后缓存到累加器RecordAccumulator中。
Sender线程负责将RecordAccumulator中消息发送到kafka中.
#
欢迎分享，转载请注明来源：内存溢出
赞
(0)
打赏
微信扫一扫
支付宝扫一扫
微信扫一扫
支付宝扫一扫
为什么人们会犹豫使用微服务？
上一篇
2022-11-11
Kafka 高效文件存储设计特点？
下一篇
2022-11-11
评论列表（0条）