0

我有一个需要使用 SSL 协议连接到 Kafka 的 .net 核心应用程序。我有一个 p12 文件,我需要将其用于与代理进行身份验证,但我无法这样做。正在使用的生产者配置是

_producerConfig = new ProducerConfig
           {
                BootstrapServers = _appSettings.EarnPublisher.Server,
                ClientId = _appSettings.ClientId,
                Partitioner = Partitioner.Consistent,
                SecurityProtocol = SecurityProtocol.Ssl,
                SslCaLocation = <filename>.p12
            };
4

0 回答 0