Kafka Linux版可通过以下方式实现权限控制:
server.properties中配置authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer。kafka-acls.sh脚本添加/删除/列出规则,如--add --allow-principal User:xxx --operation Read/Write --topic topic-name。server.properties启用SASL_PLAINTEXT/SASL_SSL,并指定JAAS配置文件(如kafka_server_jaas.conf)定义用户凭据。server.properties中配置ssl.keystore.location等参数,客户端需对应配置。kafka:kafka),限制其他用户访问。iptables或firewalld限制Kafka端口(默认9092)仅允许受信任IP访问。以上方法可组合使用,根据实际需求选择配置。