kafka同步生产者和异步生产者深入剖析


 

 

什么是kafka同步生产者,什么是kafka异步生产者?

   比如这里某个topic有3个分区。

   kafka同步生产者:这个生产者写一条消息的时候,它就立马发送到某个分区去。

  

 

 

 

     kafka异步生产者:这个生产者写一条消息的时候,先是写到某个缓冲区,这个缓冲区里的数据还没写到broker集群里的某个分区的时候,它就返回到client去了。

 

 

 

 

 

 

 
 
 
a1.sinks.k1.kafka.producer.type = sync     #kafka同步生产者



a1.sinks.k1.kafka.producer.type = async     #kafka异步生产者

 

 
 
 
 
 

 

关于源码

kafka源码解析之十六生产者流程(客户端如何向topic发送数据)

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM