在Ubuntu上配置Kafka安全可从以下方面入手:
启用SSL/TLS加密
openssl生成证书和密钥,配置server.properties中listeners=SSL://:9093等参数,指定证书路径及密码。ssl.enabled.protocols=TLSv1.2,TLSv1.3以限制协议版本。配置SASL认证
kafka_server_jaas.conf),定义用户名、密码及认证机制(如PLAIN或SCRAM-SHA-256)。server.properties中启用SASL_SSL协议,指定security.inter.broker.protocol=SASL_SSL及authorizer.class.name为AclAuthorizer。SCRAM认证,支持动态新增用户无需重启集群。权限控制(ACL)
kafka-acls.sh工具为用户/组分配主题的读写权限,如--add --allow --user user1 --operation Read --topic test。SimpleAclAuthorizer并配置ACL规则,限制未授权访问。防火墙与网络隔离
ufw或iptables限制Kafka端口(默认9092、9093)的访问,仅允许必要IP段。操作系统权限管理
审计与监控
其他安全措施
参考来源: