在CentOS上配置Kafka时,需注意以下关键点:
环境准备
java -version。zookeeper.connect参数。配置文件优化
server.properties:
broker.id:集群中每个节点唯一标识。listeners/advertised.listeners:配置监听地址及对外暴露的地址(如PLAINTEXT://your_ip:9092)。log.dirs:指定日志存储目录(建议使用SSD,避免/tmp)。zookeeper.connect:填写Zookeeper集群地址(生产环境建议配置3节点)。auto.create.topics.enable,避免误创建主题。安全配置
security.protocol=SSL及证书路径。security.inter.broker.protocol=SASL_PLAINTEXT及用户名密码。性能优化
kafka-server-start.sh中设置KAFKA_HEAP_OPTS="-Xms4g -Xmx4g"(不超过物理内存70%)。noatime,nobarrier选项。num.partitions)和副本数(default.replication.factor)。服务管理
systemd创建服务脚本,设置User和Group为专用用户(如kafka)。监控与维护
kafka-topics.sh --describe查看主题详情,kafka-consumer-groups.sh监控消费延迟。参考来源:[1,2,3,4,5,6,7,8,9,10,11]