lib/fluent/plugin/out_kafka.rb in roched-fluent-plugin-kafka-0.6.12 vs lib/fluent/plugin/out_kafka.rb in roched-fluent-plugin-kafka-0.6.13

- old
+ new

@@ -101,10 +101,10 @@ if @scram_mechanism != nil && @username != nil && @password != nil log.warn "using scram authentication" @kafka = Kafka.new(seed_brokers: @seed_brokers, client_id: @client_id, ssl_ca_cert: read_ssl_file(@ssl_ca_cert), ssl_client_cert: read_ssl_file(@ssl_client_cert), ssl_client_cert_key: read_ssl_file(@ssl_client_cert_key), sasl_scram_username: @username, sasl_scram_password: @password, sasl_scram_mechanism: @scram_mechanism) - elseif @username != nil && @password != nil + elsif @username != nil && @password != nil log.warn "using plain authentication" @kafka = Kafka.new(seed_brokers: @seed_brokers, client_id: @client_id, ssl_ca_cert: read_ssl_file(@ssl_ca_cert), ssl_client_cert: read_ssl_file(@ssl_client_cert), ssl_client_cert_key: read_ssl_file(@ssl_client_cert_key), sasl_plain_username: @username, sasl_plain_password: @password) else