SpringBoot 支持Kafka安全认证 SASL/PLAINTEXT，账号密码认证_springboot kafka 新建 plaintext用户

环境

操作系统：CentOS 7.3

Kafka Version：2.12

Zookeeper Version:3.6.1

一、Zookeeper集群配置SASL

zookeeper所有节点都是对等的，只是各个节点角色可能不相同。以下步骤所有的节点配置相同。

1、zoo.cfg文件配置

为zookeeper添加SASL支持，在配置文件zoo.cfg添加
​​​​

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

2.新建zoo_jaas.conf文件，为Zookeeper添加账号认证信息
这个文件你放在哪里随意，只要后面zkEnv配置正确的路径就好了。我是放在/home路径下。zk_server_jaas.conf文件的内容如下

Server {
 
org.apache.kafka.common.security.plain.PlainLoginModule required
 
username="kafka"
 
password="kafkapwd"
 
user_kafka="kafkapwd";
 
};

username和paasword是zk集群之间的认证密码。
user_kafka="kafkaUser65#.com"定义了一个用户"kafka"，密码是"kafkaUser65#.com"</