Я пробую такой код:
```
require "kafka"
kafka = Kafka.new(["
rc1b-xxx.mdb.yandexcloud.net:9091"], client_id: "my-application",
ssl_verify_hostname: false,
ssl_ca_cert: File.read('/usr/local/share/ca-certificates/Yandex/YandexCA.crt'),
sasl_plain_username: 'kafka-test',
sasl_plain_password: 'xxx',
sasl_scram_mechanism: 'sha512'
)
puts kafka.topics
```
Он падает `SSL_connect returned=1 errno=0 state=error: certificate verify failed (unable to get issuer certificate) (OpenSSL::SSL::SSLError)`
При этом kafkacat с теми же параметрами работает.
В поддержке посоветовали обращаться к "обращаться к специализированным форумам".