Class: WaterDrop::Producer::Builder

Inherits:
Object
  • Object
show all
Defined in:
lib/water_drop/producer/builder.rb

Overview

Class used to construct the rdkafka producer client

Instance Method Summary collapse

Instance Method Details

#call(producer, config) ⇒ Rdkafka::Producer, Producer::DummyClient

Returns raw rdkafka producer or a dummy producer when we don’t want to dispatch any messages.

Parameters:

  • producer (Producer) —

    not yet configured producer for which we want to build the client

  • config (Object) —

    dry-configurable based configuration object

Returns:

  • (Rdkafka::Producer, Producer::DummyClient) —

    raw rdkafka producer or a dummy producer when we don’t want to dispatch any messages



12
13
14
15
16
17
18
19
20
21
 
# File 'lib/water_drop/producer/builder.rb', line 12

def call(producer, config)
  return DummyClient.new unless config.deliver

  Rdkafka::Config.logger = config.logger
  Rdkafka::Config.statistics_callback = build_statistics_callback(producer, config.monitor)

  client = Rdkafka::Config.new(config.kafka.to_h).producer
  client.delivery_callback = build_delivery_callback(producer, config.monitor)
  client
end