lib/water_drop/instrumentation/callbacks/error.rb in waterdrop-2.0.7 vs lib/water_drop/instrumentation/callbacks/error.rb in waterdrop-2.1.0
- old
+ new
@@ -22,12 +22,13 @@
# Emit only errors related to our client
# Same as with statistics (mor explanation there)
return unless @client_name == client_name
@monitor.instrument(
- 'error.emitted',
+ 'error.occurred',
+ error: error,
producer_id: @producer_id,
- error: error
+ type: 'librdkafka.error'
)
end
end
end
end