ManageIQ / manageiq-messaging

MIT License
5 stars 26 forks source link

Add ssl and ca_file options to Client.open() #76

Closed agrare closed 1 year ago

agrare commented 1 year ago

Don't require users to pass in librdkafka specific options in order to use SSL / Certificate Authorities

Previously:

ManageIQ::Messaging.open(
  :protocol            => 'Kafka',
  :host                => 'localhost',
  :port                => 9092,
  :"sasl.username"     => 'user',
  :"sasl.password"     => 'password',
  :"security.protocol" => 'SASL_SSL',
  :"ssl.ca.location"   => '/path/to/cert'
)

Now:

ManageIQ::Messaging.open(
  :protocol   => 'Kafka',
  :host       => 'localhost',
  :port       => 9092,
  :username   => "user",
  :password   => 'password',
  :ssl        => true,
  :ca_file    => '/path/to/cert'
)