在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]