Class: Karafka::Setup::Configurators::WaterDrop

Inherits:
Base
  • Object
show all
Defined in:
lib/karafka/setup/configurators/water_drop.rb

Overview

Class responsible for setting up WaterDrop configuration

Instance Attribute Summary

Attributes inherited from Base

#config

Instance Method Summary collapse

Methods inherited from Base

#initialize

Constructor Details

This class inherits a constructor from Karafka::Setup::Configurators::Base

Instance Method Details

#setup ⇒ Object

Sets up a WaterDrop settings



7
8
9
10
11
12
13
14
15
 
# File 'lib/karafka/setup/configurators/water_drop.rb', line 7

def setup
  ::WaterDrop.setup do |water_config|
    water_config.send_messages = true
    water_config.connection_pool_size = config.concurrency
    water_config.connection_pool_timeout = 1
    water_config.kafka.hosts = config.kafka.hosts
    water_config.raise_on_failure = true
  end
end