lib/fluent/plugin/out_kafka.rb in roched-fluent-plugin-kafka-0.6.9 vs lib/fluent/plugin/out_kafka.rb in roched-fluent-plugin-kafka-0.6.10

@@ -95,9 +95,10 @@
       z.close
       log.info "brokers has been refreshed via Zookeeper: #{@seed_brokers}"
     end
     begin
       if @seed_brokers.length > 0
+        log.warn "user #{@username} pwd #{@password}"
         if @scram_mechanism != nil && @username != nil && @password != nil
           log.info "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)