How to connect kafka in confluent.cloud?

[xiaoronglv]

I didn't find any doc or examples

[xiaoronglv]

After digging into it for 3 hours, I finally figure it out. If you have same question, you can config it in this way.

config = {
  :"bootstrap.servers" => "your-kafka.us-west-2.aws.confluent.cloud:9092",
  :"group.id" => "ruby-test",
  :"security.protocol" => "SASL_SSL",
  :"sasl.mechanism" => "PLAIN",
  :"sasl.username" => 'your username',
  :"sasl.password" => 'your password'

}
consumer = Rdkafka::Config.new(config).consumer
consumer.subscribe("core.onboarding.employees")

consumer.each do |message|
  puts "Message received: #{message}"
end