以下是Kafka在CentOS上的安全配置方法:
server.properties
中设置security.protocol=sasl_ssl
,sasl.mechanism=PLAIN/SCRAM-SHA-256
等,创建kafka_server_jaas.conf
配置文件。security.protocol=ssl
,指定ssl.keystore.location
、ssl.truststore.location
等参数,生成证书并配置密钥库。kafka-acls.sh
工具设置用户/组对Topic的访问权限,配置authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
。firewall-cmd
限制仅允许受信任IP访问,建议部署在VPC或专用子网。unclean.leader.election.enable
防止数据丢失,定期更新Kafka版本修复漏洞,强化系统账户密码策略。参考来源: