kafka3.3.1 开启认证 SASL_PLANINTEXT

Kafka 3.3.1 中开启认证并使用SASL PLAINTEXT协议通常是为了增强安全性，允许通过简单认证和授权机制传输数据。以下是启用SASL PLAINTEXT认证的步骤：

1. **安装和配置依赖**：
首先，确保你的Kafka集群已经安装，并包含了SASL支持，包括`kafka-server-start.sh`命令行工具。

2. **启动 broker 服务**：
使用环境变量 `SASL_PLAINTEXT_LISTENERS` 和 `SASL_SSL_LISTENERS` 配置监听器，只启用PLAINTEXT模式。例如：

   bin/kafka-server-start.sh config/server.properties \
       --SASL_PLAINTEXT_LISTENERS=PLAINTEXT://localhost:9092 \
       --SASL_SSL_LISTENERS=SSL://localhost:9093

这里`9092`是PLAINTEXT默认端口，`9093`是SSL端口。

3. **创建用户和权限**：
使用`kafka-configs.sh`命令行工具创建一个SASL安全的用户名和密码，然后将其添加到Kafka的`jaas.conf`文件中。例如：

   bin/kafka-configs.sh --add-config 'SaslJaasConfig=sasl.plain.login.username=myuser,sasl.plain.login.password=mypassword'

4. **更新客户端配置**：
Kafka消费者和生产者需要设置相应的SASL配置，如`security.protocol=SASL_PLAINTEXT`和`sasl.mechanism=PLAIN`。

5. **验证连接**：
现在你可以尝试使用SASL PLAINTEXT连接到服务器，如果配置正确，应该能够成功建立连接。