ruby-kafka を使って kafka との証明書認証をサクっと確認する方法

• 概要
• 概要
• 準備
• テストコード
• 参考サイト

概要

fluent-kafka-plugin で証明書を使って kafka に接続する場合にうまく接続できない場合があると思います
そんな場合は ruby-kafka を使って確認しましょう

概要

• macOS 11.1
• Ruby 3.0.0
• ruby-kafka 1.3.0

準備

• bundle init
• vim Gemfile

gem "ruby-kafka"

• bundle install

テストコード

• vim test.rb

require 'kafka'

kafka = Kafka.new(
  ["kafka:9092"],
  ssl_ca_cert: File.read('./ca.pem'),
  ssl_client_cert: File.read('./cert.pem'),
  ssl_client_cert_key: File.read('./key.pem')
)
puts kafka

ret = kafka.deliver_message("Hello, World!", topic: "test")
puts ret

• bundle exec ruby test.rb
  
  

これでエラーが出なければ OK です
証明書が間違っている場合などは OpenSSL のエラーなどが出ると思います

参考サイト

• https://github.com/zendesk/ruby-kafka/issues/322