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