从 3.1.0 - v3.0.1 版本开始，Kafka 开始支持 SASL 协议。

配置 SASL

部署集群时，在第6步: 服务环境参数设置模块中，参数 sasl.type 下拉框中，选择目标加密算法。比如这里选择 SCRAM-SHA-256。

sasl 1
说明

参数 sasl.type 下拉框中的 无 代表着不开启 SASL 协议，默认值是 无。

其余步骤按参考前文内容正常创建 Kafka 集群即可。

验证方式

需要用户自行登录其 客户端 节点后，执行以下命令行。

  • 生产消息命令，使用 SASL 协议

    /opt/kafka/current/bin/kafka-console-producer.sh --bootstrap-server broker_ip:9092 --topic test --producer.config /ssl/kafka.config

  • 消费消息命令，使用 SASL 协议

    /opt/kafka/current/bin/kafka-console-consumer.sh --bootstrap-server broker_ip:9092 --topic test  --group test --from-beginning --consumer.config /ssl/kafka.config

第一次执行生产消息命令时，会报错，是因为 topic 不存在，但系统默认设置了 auto create topic，再次执行命令行就可以正常验证。