1. 程式人生 > >kafka(3) ===> 生產者配置

kafka(3) ===> 生產者配置

由於生產者javaAPI相關部落格有很多我就懶得寫了,這裡寫一下生產者中可以配置的引數

1.acks:

    0:不管broker接沒接收到都不去管,直接返回成功

    1:只要分割槽首領接受到了就算是成功

    all:所有副本都接受到才算是成功

2.buffer.memory:生產者用他來緩衝要傳送到伺服器上的訊息,如果應用程式傳送訊息的速度超過傳送到伺服器上的速度,有可能曹成生產者空間不足

3.compression.type:snappy、gzip、lz4 他指定了使用哪種方式對訊息進行壓縮,會佔用更多cpu減小網路開始

4.retries:如果傳送錯誤是一個臨時性錯誤,會重試幾次

5.timeout.ms/request.timeout.ms/metadata.fetch.timeout.ms

    timeout.ms指定了broker等待同步副本返回確認訊息的時間

    request:指定了生產者傳送了訊息後等待伺服器返回小時的時間

    metadata:生產者在獲取元資料時等待的時間

6.max.request.size:生產者單次傳送的最大訊息