lib/waterdrop/instrumentation/callbacks/error.rb in waterdrop-2.4.11 vs lib/waterdrop/instrumentation/callbacks/error.rb in waterdrop-2.5.0

- old
+ new

@@ -16,9 +16,11 @@ # Runs the instrumentation monitor with error # @param client_name [String] rdkafka client name # @param error [Rdkafka::Error] error that occurred # @note It will only instrument on errors of the client of our producer + # @note When there is a particular message produce error (not internal error), the error + # is shipped via the delivery callback, not via error callback. def call(client_name, error) # Emit only errors related to our client # Same as with statistics (mor explanation there) return unless @client_name == client_name