lib/racecar/runner.rb in racecar-0.3.8 vs lib/racecar/runner.rb in racecar-0.4.0.beta1
- old
+ new
@@ -25,9 +25,12 @@
ssl_ca_cert_file_path: config.ssl_ca_cert_file_path,
ssl_client_cert: config.ssl_client_cert,
ssl_client_cert_key: config.ssl_client_cert_key,
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,
)
@consumer = kafka.consumer(
group_id: config.group_id,
offset_commit_interval: config.offset_commit_interval,