class Kafka::Retryable::Config
configurator for setting up all the configurable settings for pheromone
Public Class Methods
setup(&block)
click to toggle source
# File lib/kafka/retryable/config.rb, line 19 def setup(&block) configure(&block) setup_waterdrop if config.buffer.kafka.seed_brokers end
setup_waterdrop()
click to toggle source
# File lib/kafka/retryable/config.rb, line 24 def setup_waterdrop WaterDrop.setup do |waterdrop_config| waterdrop_config.deliver = config.failure_handling.enabled waterdrop_config.kafka.seed_brokers = config.buffer.kafka.seed_brokers end end