kafka本地如何开启SASL机制

How to enable SASL mechanism in kafka locally

如何使用 JAAS 身份验证为 kafka 启用 SASL 机制?因此 consumer/producer 必须提供用户名和密码才能在代理中发布

文档中的 Authentication using SASL section 详细描述了在 Kafka 中启用 SASL 身份验证的过程。我建议您遵循官方文档,因为它包含所有机制的说明和生产环境的建议。

要了解一些背景知识,您需要:

  1. 使用 KafkaServer 块和特定机制的配置为代理创建 JAAS 文件。

  2. -Djava.security.auth.login.config=<PATH_TO_JAAS_FILE> 添加到您的代理 JVM 命令行参数。

  3. 通过 security.protocolsasl.mechanismsasl.jaas.config 设置将客户端配置为使用 SASL。