什么是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發送數據)