Class: Deimos::Backends::KafkaAsync

Inherits:
Base
  • Object
show all
Includes:
Phobos::Producer
Defined in:
lib/deimos/backends/kafka_async.rb

Overview

Backend which produces to Kafka via an async producer.

Class Method Summary collapse

Methods inherited from Base

publish

Class Method Details

.execute(producer_class:, messages:) ⇒ Object

:nodoc:



16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/deimos/backends/kafka_async.rb', line 16

def self.execute(producer_class:, messages:)
  Deimos.instrument(
    'produce',
    producer: producer_class,
    topic: producer_class.topic,
    payloads: messages.map(&:payload)
  ) do
    producer.async_publish_list(messages.map(&:encoded_hash))
    Deimos.config.metrics&.increment(
      'publish',
      tags: %W(status:success topic:#{producer_class.topic}),
      by: messages.size
    )
  end
end

.shutdown_producer ⇒ Object

Shut down the producer cleanly.



10
11
12
13
 
# File 'lib/deimos/backends/kafka_async.rb', line 10

def self.shutdown_producer
  producer.async_producer_shutdown
  producer.kafka_client&.close
end