如何在C# Kafka生产者/消费者配置中启用TLS1.2？（.NET Core3.1/Linux）

Confluent.Kafka依赖librdkafka实现底层通信，对应Java里的ssl.enabled.protocols配置，你可以通过以下方式指定仅使用TLS 1.2：

核心配置项 #

你需要设置两个关键配置参数：

• ssl.protocol：指定默认使用的SSL/TLS协议版本，设为TLSv1_2
• ssl.enabled.protocols：控制允许启用的SSL/TLS协议范围，同样设为TLSv1_2

代码示例 #

Producer配置 #

var producerConfig = new ProducerConfig
{
    BootstrapServers = "your-kafka-broker-address:9093",
    SecurityProtocol = SecurityProtocol.Ssl,
    // 用枚举直接指定TLS 1.2
    SslProtocol = SslProtocol.Tls12,
    // 显式限制允许的协议（可选，与上面枚举配合更严谨）
    "ssl.enabled.protocols" = "TLSv1_2",
    // 补充必要的SSL证书配置
    SslCaLocation = "/etc/ssl/certs/ca-certificates.crt"
};

using var producer = new ProducerBuilder<Null, string>(producerConfig).Build();

Consumer配置 #

var consumerConfig = new ConsumerConfig
{
    BootstrapServers = "your-kafka-broker-address:9093",
    GroupId = "your-consumer-group-id",
    AutoOffsetReset = AutoOffsetReset.Earliest,
    SecurityProtocol = SecurityProtocol.Ssl,
    SslProtocol = SslProtocol.Tls12,
    "ssl.enabled.protocols" = "TLSv1_2",
    SslCaLocation = "/etc/ssl/certs/ca-certificates.crt"
};

using var consumer = new ConsumerBuilder<Ignore, string>(consumerConfig).Build();

注意事项 #

• 使用SslProtocol.Tls12枚举时，底层会自动设置对应协议，但显式配置ssl.enabled.protocols能更明确地限制协议范围，避免意外启用旧版本协议
• .NET Core 3.1在Linux上依赖系统OpenSSL，确保你的系统OpenSSL版本支持TLS 1.2（主流Linux发行版的默认版本都满足）
• 若不需要兼容旧协议，仅保留TLSv1_2即可，提升通信安全性

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