lib/water_drop/producer/async.rb in waterdrop-2.0.6 vs lib/water_drop/producer/async.rb in waterdrop-2.0.7

@@ -17,11 +17,11 @@
         ensure_active!
         validate_message!(message)
 
         @monitor.instrument(
           'message.produced_async',
-          producer: self,
+          producer_id: id,
           message: message
         ) { client.produce(**message) }
       end
 
       # Produces many messages to Kafka and does not wait for them to be delivered
@@ -38,10 +38,10 @@
         ensure_active!
         messages.each { |message| validate_message!(message) }
 
         @monitor.instrument(
           'messages.produced_async',
-          producer: self,
+          producer_id: id,
           messages: messages
         ) do
           messages.map { |message| client.produce(**message) }
         end
       end