提升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)。具体参数需根据业务负载和硬件环境调整,建议先在测试环境验证优化效果。