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

@@ -107,9 +107,10 @@
           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
+          log.warn "no auth"
           @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_gssapi_principal: @principal, sasl_gssapi_keytab: @keytab)
         end
         log.info "initialized kafka producer: #{@client_id}"