lib/waterdrop/clients/rdkafka.rb in waterdrop-2.6.9 vs lib/waterdrop/clients/rdkafka.rb in waterdrop-2.6.10

@@ -17,9 +17,10 @@
 
           # This callback is not global and is per client, thus we do not have to wrap it with a
           # callbacks manager to make it work
           client.delivery_callback = Instrumentation::Callbacks::Delivery.new(
             producer.id,
+            producer.transactional?,
             producer.config.monitor
           )
 
           # Switch to the transactional mode if user provided the transactional id
           client.init_transactions if config.key?(:'transactional.id')