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

@@ -17,10 +17,10 @@
       transactional: false,
       transactional_id: nil,
       transactional_timeout: DEFAULT_TRANSACTION_TIMEOUT
     )
       @cluster = cluster
-      @logger = logger
+      @logger = TaggedLogger.new(logger)
 
       @transactional = transactional
       @transactional_id = transactional_id
       @transactional_timeout = transactional_timeout
       @transaction_state = Kafka::TransactionStateMachine.new(logger: logger)