降低Linux Kafka消息延遲可從以下方面優化:
生產者優化
batch.size
(如32KB),適當調整linger.ms
(如5-10ms),減少網絡請求次數。消費者優化
fetch.min.bytes
和max.poll.records
,減少拉取頻率。commitAsync
減少提交延遲。Broker與集群優化
num.io.threads
(CPU核數×2~4)、socket.buffer
(1MB),啟用零拷貝。-Xms -Xmx
為6-8GB,使用G1垃圾回收器減少GC停頓。網絡與系統優化
net.core.rmem/wmem
增大TCP緩沖區,啟用BBR擁塞控制算法。監控與調優
關鍵平衡:需根據業務場景權衡延遲與吞吐量,例如高吞吐場景可適當增加延遲,實時場景需優先降低延遲。