以下是在Debian上降低Kafka消費者延遲的優化措施:
fetch.min.bytes(如1MB)和fetch.max.wait.ms(如50-100ms),減少網絡請求頻率。listener.concurrency配置多線程消費。enable.auto.commit=false,配合commitSync/commitAsync確保處理完成后再提交,避免重復消費。session.timeout.ms(如10秒)和max.poll.interval.ms(如30秒),快速檢測消費者狀態。kafka-consumer-groups.sh監控滯后情況,動態調整參數。注:需根據業務場景(如高吞吐/低延遲)選擇合適參數,優先測試驗證后再應用到生產環境。