lib/kafka/sasl_authenticator.rb in ruby-kafka-0.7.5 vs lib/kafka/sasl_authenticator.rb in ruby-kafka-0.7.6.beta1

@@ -7,10 +7,10 @@
 module Kafka
   class SaslAuthenticator
     def initialize(logger:, sasl_gssapi_principal:, sasl_gssapi_keytab:,
                    sasl_plain_authzid:, sasl_plain_username:, sasl_plain_password:,
                    sasl_scram_username:, sasl_scram_password:, sasl_scram_mechanism:)
-      @logger = logger
+      @logger = TaggedLogger.new(logger)
 
       @plain = Sasl::Plain.new(
         authzid: sasl_plain_authzid,
         username: sasl_plain_username,
         password: sasl_plain_password,