提升CentOS上Kafka性能可从硬件、配置、网络及监控等方面入手,具体如下:
num.partitions
:设置为与消费者线程数相近,提升并行处理能力。num.io.threads
:设为CPU核数的50%~100%,优化磁盘读写。log.segment.bytes
:设为1GB~2GB,减少日志段切换开销。compression.type
:启用lz4
或snappy
压缩,降低网络传输量。batch.size
:设为1MB~5MB,减少网络请求次数。linger.ms
:设为100ms~500ms,平衡延迟与吞吐量。fetch.max.bytes
:设为1MB~5MB,提升单次拉取效率。max.poll.records
:根据业务需求调整,减少拉取频次。atime
更新,使用noatime
挂载文件系统。vm.swappiness
为1,减少swap使用。net.core.rmem_max
和net.core.wmem_max
)。具体参数需根据业务负载和硬件环境调整,建议先在测试环境验证优化效果。