kaushalprasad Ответов: 1

Как использовать сертификат SSL в Кафка потребителя, используя ASP.NET


Я делаю потребителя внутри Asp.Net используя слияние Кафки. Confluent kafka скачан из пакета Nuget. Я хочу подключиться к удаленному серверу, где развернута kafka, используя SSL-сертификат. я использую config для подключения

var configSSL = новый ConsumerConfig
{
Группы = группы,
BootstrapServers = надо установить до начала использования,
SslCaLocation = "файл config/файл testcert.Р12",
SecurityProtocol = SecurityProtocol.использование SSL,
AutoOffsetReset = AutoOffsetReset.Раннее,
Debug = "все",
};
Я не могу подключиться kafak сервер с помощью SSL-сертификата, и я получаю ошибки %3/1593785896.458|протокол SSL|rdkafka#потребительски-1| [thrd:приложения]: .\крипто\био\bss_file.с:175: ошибка:02001003:деятельность библиотек системы:функции fopen:нет такого процесса: функции fopen('файл config\файл testcert.Р12','Р')

Что я уже пробовал:

I am making consumer in Asp.Net using Confluent Kafka. Confluent kafka downloaded from Nuget package. I want to connect with remote server where kafka is deployed using SSL certificate. i am using config for connection

 var configSSL = new ConsumerConfig
            {
                GroupId = groupID,
                BootstrapServers = serverUrl,
               SslCaLocation = "Config/testcert.p12",             
                SecurityProtocol = SecurityProtocol.Ssl,               
                AutoOffsetReset = AutoOffsetReset.Earliest,
                Debug = "all",
            };

1 Ответов

Рейтинг:
9

Garth J Lancaster

Этот

Цитата:
функции fopen:нет такого процесса: функции fopen('файл config\файл testcert.Р12','Р')
в сообщении об ошибке очень наводит на мысль, что он не может найти testcert.p12 или есть другие проблемы с этим файлом сертификата

Поскольку вы не указываете, находится ли ваш файл в Windows или *nix (не то чтобы это действительно имело значение), пожалуйста, попробуйте полностью указать путь к вашему файлу testcert.p12

Еще один вопрос, который я хотел бы задать, заключается в том, уверены ли вы, что testcert.p12-это правильный формат, в отличие от testcert.pem ?


kaushalprasad

Спасибо за ваше обновление. Теперь я исправил проблему пути и получаю новую ошибку:
Произошла ошибка: ошибка ssl.ca.location: нет ошибки

Да, testcert.p12 действителен. Я имею в виду, что p12-это действительное расширение .Разработчик на Java успешно может подключиться с тем же сертификатом.