.NET环境下使用Confluent.Kafka配置JAAS认证连接Kafka问题咨询

解决方案 #

.NET 版本的 Confluent.Kafka 不需要直接配置完整的 sasl.jaas.config 字符串，JAAS 中的用户名、密码参数可以通过 SaslUsername 和 SaslPassword 两个配置项直接赋值即可，修改后的代码如下：

var config = new ProducerConfig
{
    BootstrapServers = "pkc.....cloud:9092",
    SslEndpointIdentificationAlgorithm = SslEndpointIdentificationAlgorithm.Https,
    SecurityProtocol = SecurityProtocol.SaslSsl,
    SaslMechanism = SaslMechanism.Plain,
    // 补充JAAS对应的用户名密码配置
    SaslUsername = "你的JAAS配置中username字段双引号内的值",
    SaslPassword = "你的JAAS配置中password字段双引号内的值"
};

补充注意事项 #

• 以上配置方式仅针对你当前使用的 PLAIN 类型 SASL 机制生效，如果你后续切换为其他SASL机制（如SCRAM、OAUTHBEARER等），配置逻辑会有对应调整。
• 生产环境请勿把用户名密码硬编码在代码中，建议通过环境变量、加密配置中心等安全方式读取敏感信息。

内容的提问来源于stack exchange，提问作者Cassiano