Module: Kafka::Retryable::HandleFailure::InstanceMethods

Defined in:
lib/kafka/retryable/handle_failure.rb

Instance Method Summary collapse

Instance Method Details

#handle_failure(message) ⇒ Object

sent to Kafka. kafka_retryable does not perform any modifications on this message and sends it as it is to Kafka

Parameters:

  • message (Hash|String) —

    this should be the exact message the needs to be



44
45
46
47
48
49
 
# File 'lib/kafka/retryable/handle_failure.rb', line 44

def handle_failure(message)
  yield
rescue => error
  run_failure_hooks(error, message)
  run_after_failure_action(error, message)
end