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