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,