我有一个需要使用 SSL 协议连接到 Kafka 的 .net 核心应用程序。我有一个 p12 文件,我需要将其用于与代理进行身份验证,但我无法这样做。正在使用的生产者配置是
_producerConfig = new ProducerConfig
{
BootstrapServers = _appSettings.EarnPublisher.Server,
ClientId = _appSettings.ClientId,
Partitioner = Partitioner.Consistent,
SecurityProtocol = SecurityProtocol.Ssl,
SslCaLocation = <filename>.p12
};