class Honeybadger::Karafka::ErrorsListener
Public Instance Methods
Source
# File lib/honeybadger/karafka.rb, line 9 def on_error_occurred(event) context = { type: event[:type] } tags = ["type:#{event[:type]}"] if (consumer = event.payload[:caller]).respond_to?(:messages) messages = consumer.messages metadata = messages.metadata consumer_group_id = consumer.topic.consumer_group.id context[:topic] = metadata.topic context[:partition] = metadata.partition context[:consumer_group] = consumer_group_id end Honeybadger.notify(event[:error], context: context) end
Sends error details to Honeybadger
@param event [Karafka::Core::Monitoring::Event]