kafka配置账号密码连接zookeeper
时间: 2023-11-16 10:02:16 浏览: 413
要配置账号密码连接Kafka和Zookeeper,需要完成以下步骤:
1. 在Zookeeper上配置账号密码:
- 打开Zookeeper的配置文件`zoo.cfg`,找到`authProvider.1`这一行,去掉前面的注释`#`。
- 在同一行的末尾添加`org.apache.zookeeper.server.auth.DigestAuthenticationProvider`,表示使用`Digest`认证。
- 在`zoo.cfg`的末尾添加账号密码信息,格式为`username:password`,每个账号密码独占一行。例如:
```
authProvider.1=org.apache.zookeeper.server.auth.DigestAuthenticationProvider
requireClientAuthScheme=true
jaasLoginRenew=3600000
admin:adminpwd
user:userpwd
```
2. 在Kafka上配置账号密码:
- 打开Kafka的配置文件`server.properties`。
- 找到并修改以下两行配置:
```
zookeeper.set.acl=true
zookeeper.sasl.client=false
```
- 在同一文件中找到并修改以下两行配置,将`username`和`password`替换为在Zookeeper中配置的账号密码信息:
```
zookeeper.authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
zookeeper.authProvider.2=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
```
- 保存并关闭`server.properties`。
3. 重启Zookeeper和Kafka:
- 重启Zookeeper和Kafka以使配置生效。可以在终端执行以下命令:
```
zkServer.sh restart
kafka-server-start.sh -daemon config/server.properties
```
完成上述步骤后,Kafka将使用配置的账号密码连接Zookeeper。
阅读全文