在Ubuntu上保障Kafka安全可从以下方面入手:
server.properties中设置security.protocol=SSL及证书路径。SASL_PLAINTEXT或SASL_SSL,通过JAAS配置文件定义用户名/密码(如PLAIN机制),或集成Kerberos。super.users配置超级用户权限。kafka-acls.sh工具动态管理。authorizer.class.name为SimpleAclAuthorizer并启用ACL。ufw)限制Kafka端口(默认9092)的访问,仅允许可信IP。参考来源:[1,2,3,4,5,6,7,8,9,10,12,13,14]