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发送数据)

原文地址:https://www.cnblogs.com/zlslch/p/6764742.html