Class: Kafka::Retryable::Config

Inherits:
Object
  • Object
show all
Extended by:
Dry::Configurable
Defined in:
lib/kafka/retryable/config.rb

Overview

configurator for setting up all the configurable settings for pheromone

Class Method Summary collapse

Class Method Details

.setup(&block) ⇒ Object 



19
20
21
22
 
# File 'lib/kafka/retryable/config.rb', line 19

def setup(&block)
  configure(&block)
  setup_waterdrop if config.buffer.kafka.seed_brokers
end

.setup_waterdrop ⇒ Object 



24
25
26
27
28
29
 
# 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