柚子快報激活碼778899分享:分布式 Kafka常見參數(shù)
柚子快報激活碼778899分享:分布式 Kafka常見參數(shù)
參數(shù)名含義默認值解釋max.request.size生產(chǎn)端:最大請求字節(jié)大小1MB如果生產(chǎn)請求消息體大小大于該值,客戶端生產(chǎn)時會報錯max.poll.records消費端:一次poll()請求最大拉取消息條數(shù)500條如果單條消息處理時間長,需要減少該參數(shù)值,反之增加fetch.min.bytes消費端:一次poll()請求最小返回字節(jié)大小1增加該值可以提高吞吐量,同時也會產(chǎn)生一定延遲fetch.max.bytes消費端:一次poll()請求最大返回字節(jié)大小50MB注意:若在第一個非空分區(qū)中拉取的第一條消息大于該值,消息仍會被返回fetch.max.wait.ms消費端:返回消息大小不滿足fetch.min.bytes時最長等待時間500ms與fetch.min.bytes參數(shù)共同作用batch.sizelinear.ms與batch.size共同控制消息異步發(fā)送頻率;當batch大小達到batch.size或滿足linger.ms時間間隔時,消息16KB如果期望提高吞吐量,可以增加至 100000–200000;如果期望低生產(chǎn)時延,則建議使用默認值;linger.mslinear.ms與batch.size共同控制消息異步發(fā)送頻率;當batch大小達到batch.size或滿足linger.ms時間間隔時,消息0如果希望提高吞吐量,可以增加至 10–100;如果期望低生產(chǎn)時延,則建議使用默認值message.max.bytes服務(wù)端配置,控制服務(wù)端接受可的最大生產(chǎn)批次消息大小1MB如果生產(chǎn)請求消息體大小大于該值,服務(wù)端會返回錯誤響應(yīng);如果開啟了消息壓縮,則校驗壓縮后消息體大小max.partition.fetch.bytes消費端:一次poll()請求每個分區(qū)最大返回字節(jié)大小1MB
柚子快報激活碼778899分享:分布式 Kafka常見參數(shù)
好文鏈接
本文內(nèi)容根據(jù)網(wǎng)絡(luò)資料整理,出于傳遞更多信息之目的,不代表金鑰匙跨境贊同其觀點和立場。
轉(zhuǎn)載請注明,如有侵權(quán),聯(lián)系刪除。