потребительская либрдкафка и конфигурация ssl - PullRequest
Новая
       49

потребительская либрдкафка и конфигурация ssl

1 голос
/ 31 мая 2019

Я использую librdkafka в качестве потребителя клиента и настроил посредника и клиента для поддержки SSL, для посредника: 

listeners = PLAINTEXT://172.20.54.9:9092,SSL://172.20.54.9:9093
ssl.keystore.location=E:/project_files/Project/kafka_2.11-2.1.0/config/kafka.server.keystore.jks
ssl.keystore.password=ismail
ssl.key.password=ismail
ssl.truststore.location=E:/project_files/Project/kafka_2.11-2.1.0/config/kafka.server.truststore.jks
ssl.truststore.password=password

на стороне клиента. Я использую эту конфигурацию:

rd_kafka_conf_set(conf, "metadata.broker.list", "172.20.54.9:9093",
                      NULL, 0);
rd_kafka_conf_set(conf, "security.protocol", "ssl",
                      NULL, 0);
rd_kafka_conf_set(conf, "ssl.ca.location", "/usr/bin/NetSens/CARoot.pem",
                      NULL, 0);
rd_kafka_conf_set(conf, "ssl.certificate.location", "/usr/bin/NetSens/certificate.pem",
                      NULL, 0);
rd_kafka_conf_set(conf, "ssl.key.location", "/usr/bin/NetSens/key.pem",
                      NULL, 0);
rd_kafka_conf_set(conf, "ssl.key.password", "password",
                      NULL, 0);

И я получаю эту ошибку: 

1559309856.897 RDKAFKA-3-ERROR: rdkafka#consumer-1: [thrd:ssl://172.20.54.9:9093/bootstrap]: ssl://172.20.54.9:9093/bootstrap: SSL handshake failed: ../ssl/record/ssl3_record.c:252: error:1408F10B:SSL routines:ssl3_get_record:wrong version number:  (after 7ms in state CONNECT)

Для получения дополнительной информации у меня параллельно есть другой клиент python kafka, использующий те же сертификаты и ключи, и он работает нормально.Я буду очень благодарен за любую помощь.

1 Ответ

1 голос
/ 31 мая 2019

Я считаю, что ваша проблема связана с этой проблемой .

Вы можете исправить это, добавив -keyalg RSA при вызове keytool -genkey для генерации сертификатов.

...