基於Kafka 0 9版本使用ACL進行許可權控制

kafka附帶乙個可插拔的認證，並使用zookeeper來儲存所有的acl。kafka的acl在一般格式定義"principal p is [allowed/denied] operation o from host h on resource r」，你可以閱讀更多關於kip-11的結構，為了新增，刪除或列表，你可以使用kafka認證cli。預設情況下，如果資源r沒有相關acl，除了超級使用者，沒有使用者允許訪問，如果你想改變它的行為，你可以在broker.properties配置：

allow.everyone.if.no.acl.found=true

你也可以在broker.properties新增超級使用者，像這樣（注意分隔符是分號，因為ssl的使用者名稱可能包含逗號）。

super.users=user:bob;user:alice

1.首先，要使用 kafka acl進行許可權驗證，要在server.properties 上新增配置（非常重要）

authorizer.class.name = kafka.security.auth.******aclauthorizer

2.為集群賦予許可權

kafka_2.11-0.9.0.1/bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --operation all --allow-principal user:* --allow-host 192.168.70.101 --add --cluster

3.啟動集群

略4.建立topic並賦許可權

kafka-topics.sh --create --zookeeper hadoop01:2181 --replication-factor 1 --partitions 1 --topic test1

kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --operation write --operation read --allow-principal user:* --allow-host 192.168.8.91 --add --topic test1

這樣，我們就可以在91節點上對 topic test1擁有讀與寫的許可權，也就是說可以在91節點上建立生產者和消費者

基於Kafka 0 9版本使用ACL進行許可權控制

02 10版本kafka安裝部署

Docker 架構基於 1 2 版本

低於1 0版本 pod使用

基於Kafka 0 9版本 使用ACL進行許可權控制

02 10版本kafka安裝部署

Docker 架構 基於 1 2 版本

低於1 0版本 pod使用

相關推薦

基於Kafka 0 9版本使用ACL進行許可權控制

Docker 架構基於 1 2 版本