lib/karafka/instrumentation/callbacks/error.rb in karafka-2.0.28 vs lib/karafka/instrumentation/callbacks/error.rb in karafka-2.0.29

@@ -26,9 +26,10 @@
           # Same as with statistics (mor explanation there)
           return unless @client_name == client_name
 
           @monitor.instrument(
             'error.occurred',
+            caller: self,
             subscription_group_id: @subscription_group_id,
             consumer_group_id: @consumer_group_id,
             type: 'librdkafka.error',
             error: error
           )