Как подключиться к Yandex.Cloud Kafka Managed Service

67 views
Skip to first unread message

Леонид

unread,
Jan 12, 2023, 2:39:28 AM1/12/23
to RubyOnRails to russian
Я пробую такой код:

```
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 с теми же параметрами работает.

В поддержке посоветовали обращаться к "обращаться к специализированным форумам".
Reply all
Reply to author
Forward
Message has been deleted
0 new messages