以下是Kafka在Linux中的性能调优策略:
vm.swappiness=1)。tcp_no_delay、tcp_keepalive_time)。ulimit -n 65535增加限制,支持更多并发连接。vm.dirty_background_ratio和vm.dirty_ratio:控制在5%-20%,减少脏页刷新频率。swapoff -a)或限制其使用。num.network.threads:设置为CPU核心数的2倍。num.io.threads:设置为CPU核心数的4倍。log.retention.hours:根据业务需求设置保留时间(如168小时)。log.segment.bytes:调整为1GB-2GB,优化日志清理效率。batch.size(生产者):增大至16KB-64KB,减少网络请求次数。linger.ms(生产者):设置为5-10ms,合并小批次消息。fetch.min.bytes(消费者):增大至1KB-4KB,减少拉取频率。compression.type=gzip/snappy,利用Sendfile技术减少数据拷贝。-Xms和-Xmx为相同值(如8GB-16GB),避免动态扩展开销。-XX:+UseG1GC),并设置-XX:MaxGCPauseMillis=200控制暂停时间。注:调优前需在测试环境验证,优先通过监控定位瓶颈,避免盲目调整。
参考来源: