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