class Kafka::Retryable::Policies::KafkaHandler
Policy for storing failed messages in a queue on Kafka
Public Class Methods
new(message, topic)
click to toggle source
# File lib/kafka/retryable/policies/kafka_handler.rb, line 7 def initialize(message, topic) @message = message @topic = topic end
Public Instance Methods
perform_failure_recovery()
click to toggle source
# File lib/kafka/retryable/policies/kafka_handler.rb, line 12 def perform_failure_recovery return unless Kafka::Retryable.enabled? Kafka::Retryable::MessageDispatcher::Kafka.new(@message, @topic).perform end