lib/racecar/runner.rb in racecar-0.5.0.beta1 vs lib/racecar/runner.rb in racecar-0.5.0.beta2
- old
+ new
@@ -30,9 +30,10 @@
sasl_plain_username: config.sasl_plain_username,
sasl_plain_password: config.sasl_plain_password,
sasl_scram_username: config.sasl_scram_username,
sasl_scram_password: config.sasl_scram_password,
sasl_scram_mechanism: config.sasl_scram_mechanism,
+ sasl_over_ssl: config.sasl_over_ssl,
ssl_ca_certs_from_system: config.ssl_ca_certs_from_system,
)
@consumer = kafka.consumer(
group_id: config.group_id,