6 zookeeper 认证支持

创建 JAAS login file

创建 conf/zookeeper_server_jaas.conf 文件，配置用户名和密码：

Server {
   org.apache.zookeeper.server.auth.DigestLoginModule required
   user_admin="password"
   user_alice="password";
};

运行 zookeeper 时需要将 jaas 文件路径加入到 JVM 参数中，可以在 conf/zookeeper-env.sh 中增加：

export SERVER_JVMFLAGS="-Djava.security.auth.login.config=/usr/local/zookeeper/conf/zookeeper_server_jaas.conf"

zoo.cfg

authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
requireClientAuthScheme=sasl
jaasLoginRenew=3600000

zkCli 访问

客户端通过 SASL 认证访问，创建 conf/zookeeper_client_jaas.conf 文件：

Client {
   org.apache.zookeeper.server.auth.DigestLoginModule required
   username="admin"
   password="password";
};

运行 client 时需要将 jaas 文件路径加入到 JVM 参数中，可以在 conf/zookeeper-env.sh 中增加：

export CLIENT_JVMFLAGS="-Djava.security.auth.login.config=/usr/local/zookeeper/conf/zookeeper_client_jaas.conf"

通过 zkCli.sh 访问：

./bin/zkCli.sh -server <zk_host>:2181

kafka 访问

增加 jaas 文件，如 kafka_server_jaas.conf，添加以下内容：

Client {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="admin"
    password="password";
};

运行 kafka 时需要将 jaas 文件加入到 JVM 参数中

# bin/kafka-server-start.sh
# bin/zookeeper-shell.sh
export KAFKA_OPTS='-Djava.security.auth.login.config=/usr/local/kafka/config/kafka_server_jaas.conf'

通过 zookeeper-shell.sh 访问 zk 服务：

./bin/zookeeper-shell.sh <zk_host>:2181

kafka 服务在创建 znode 时开启 ACL

zookeeper.set.acl=true

acl 操作

设置 acl

[zk: localhost:2181(CONNECTED) 6] setAcl /brokers sasl:bcekafka:rwcda,world:anyone:r

查看 acl

[zk: localhost:2181(CONNECTED) 7] getAcl /brokers
'sasl,'bcekafka
: cdrwa
'world,'anyone
: r

格式为 '<认证方式> '<用户名>: <权限列表>

权限分为 5 种：

• c: create
• d: delete
• r: read
• w: write
• a: admin