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