如何配置Kafka账号密码

要配置账号密码连接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。