class Kafka::Retryable::PolicyFinder

Find policy based on the failure handler settings

Constants

POLICY_MAPPING

Public Class Methods

find_by(buffer) click to toggle source
# File lib/kafka/retryable/policy_finder.rb, line 13
def self.find_by(buffer)
  POLICY_MAPPING[buffer].tap do |policy|
    raise Kafka::Retryable::InvalidPolicy.new('Policy not found') unless policy
  end
end