kafka有同步（sync）、非同步（async）以及oneway這三種傳送方式，某些概念上區分也可以分為同步和非同步兩種，同步和非同步的傳送方式通過“producer.type”引數指定，而oneway由“request.require.acks”引數指定。

1. sync vs async

在官方文件Producer Configs中有如下：

翻譯過來就是：
producer.type的預設值是sync，即同步的方式。這個引數指定了在後臺執行緒中訊息的傳送方式是同步的還是非同步的。如果設定成非同步的模式，可以執行生產者以batch的形式push資料，這樣會極大的提高broker的效能，但是這樣會增加丟失資料的風險。

對於非同步模式，還有4個配套的引數，如下：

以batch的方式推送資料可以極大的提高處理效率，kafka producer可以將訊息在記憶體中累計到一定數量後作為一個batch傳送請求。batch的數量大小可以通過producer的引數（batch.num.messages）控制。通過增加batch的大小，可以減少網路請求和磁碟IO的次數，當然具體引數設定需要在效率和時效性方面做一個權衡。在比較新的版本中還有batch.size這個引數。

2. 題外話：

producers可以一步的並行向kafka傳送訊息，但是通常producer在傳送完訊息之後會得到一個響應，返回的是offset值或者傳送過程中遇到的錯誤。這其中有個非常重要的引數“request.required.acks”，這個引數決定了producer要求leader partition收到確認的副本個數，如果acks設定為0，表示producer不會等待broker的相應，所以，producer無法知道訊息是否發生成功，這樣有可能導致資料丟失，但同時，acks值為0會得到最大的系統吞吐量。若acks設定為1，表示producer會在leader partition收到訊息時得到broker的一個確認，這樣會有更好的可靠性，因為客戶端會等待知道broker確認收到訊息。若設定為-1，producer會在所有備份的partition收到訊息時得到broker的確認，這個設定可以得到最高的可靠性保證。

3. oneway

前面只提到了sync和async，那麼oneway是什麼呢？
oneway是隻顧訊息發出去而不管死活，訊息可靠性最低，但是低延遲、高吞吐，這種對於某些完全對可靠性沒有要求的場景還是適用的，即request.required.acks設定為0。

4. 一般配置

對於sync的傳送方式：
producer.type=sync
request.required.acks=1

對於async的傳送方式：
producer.type=async
request.required.acks=1
queue.buffering.max.ms=5000
queue.buffering.max.messages=10000
queue.enqueue.timeout.ms = -1
batch.num.messages=200

對於oneway的傳送傳送：
producer.type=async
request.required.acks=0

歡迎支援《RabbitMQ實戰指南》以及關注微信公眾號：朱小廝的部落格。