bootstrap.servers:連接broker的ip和port
key.serializer
value.serializer
acks:[all, -1, 0, 1]
0:不等寫入就可以返回
1:只寫leader本地就可以返回
-1:寫入min.insync.replicas數(shù)才返回
buffer.memory
compression.type 壓縮類型
retries:重試次數(shù)
batch.size:sender發(fā)一次請求最大字節(jié)數(shù)造锅。達到大小則開始發(fā)送
linger.ms:sender線程發(fā)送請求的時間間隔
client.id:客戶端唯一id 用于定位問題
connections.max.idle.ms
max.block.ms:send和partitionsFor函數(shù)最大block時間(有可能sender隊列已經(jīng)滿了,或者meta數(shù)據(jù)已經(jīng)過期了陨界,導(dǎo)致無法發(fā)送)
max.request.size:一次請求最大字節(jié)數(shù)
partitioner.class:定義對消息Key分區(qū)的類
receive.buffer.bytes:
request.timeout.ms:客戶端側(cè)超時時長
timeout.ms:當設(shè)置了ack=-1時,leader等待follower返回的最長時間,這個是服務(wù)端限制的時間库物,不包括網(wǎng)絡(luò)時長
send.buffer.bytes
block.on.buffer.full:當緩沖區(qū)滿時無法發(fā)送數(shù)據(jù)時是否block
interceptor.classes:攔截器的類
max.in.flight.requests.per.connection:最大同時允許produce請求數(shù)疫萤,如果設(shè)置為1芝囤,相當于kafka是同步的雹拄。但是設(shè)置為1以上收奔,可以增加吞吐量,但是可能會亂序(當發(fā)生重試)滓玖。
metadata.fetch.timeout.ms:元數(shù)據(jù)獲取超時時間
metadata.max.age.ms:元數(shù)據(jù)過期時間
reconnect.backoff.ms:重新連接時超時時間
retry.backoff.ms:向broker發(fā)送數(shù)據(jù)失敗后的重試間隔時間