Kafka在Debian上的性能调优可从配置、硬件、系统层面入手,具体方法如下:
Broker配置
num.partitions
:设置为消费者线程数的1-2倍,提升并行处理能力。num.io.threads
:建议设为CPU核心数的50%,优化磁盘I/O。compression.type
:选择lz4
或snappy
压缩,平衡CPU与吞吐量。batch.size
:设为1MB-2MB,减少网络请求次数。linger.ms
:设为100ms-200ms,允许更多消息合并发送。Producer/Consumer配置
fetch.min.bytes
:设为1MB,减少消费者拉取频次。max.poll.records
:适当增加单次拉取消息量,提升消费效率。存储优化
log.dirs
配置为多磁盘路径,分散写入压力。网络优化
net.core.rmem_max
)提升网络吞吐。JVM调优
多节点部署
replication.factor
)设为2-3,确保数据可靠性。监控与调优
log.segment.bytes
参数优化文件读写。具体参数需根据业务负载测试调整,优先保证数据可靠性的前提下提升性能。
参考来源: