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