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访问。以上方法可组合使用,根据实际需求选择配置。