Class: Deimos::Backends::KafkaAsync

Inherits:

Base

• Object
• Base
• Deimos::Backends::KafkaAsync

Includes:

Phobos::Producer

Defined in:

lib/deimos/backends/kafka_async.rb,
sig/defs.rbs

Overview

Backend which produces to Kafka via an async producer.

Class Method Summary

• .execute(producer_class:, messages:) ⇒ void

  :nodoc:.

• .shutdown_producer ⇒ void

  Shut down the producer cleanly.

Methods inherited from Base

publish

Class Method Details

.execute(producer_class:, messages:) ⇒ void

This method returns an undefined value.

:nodoc:

Parameters:

• producer_class: (singleton(Deimos::Producer))
• messages: (::Array[Deimos::Message])

# File 'lib/deimos/backends/kafka_async.rb', line 9

def self.execute(producer_class:, messages:)
  Deimos.producer_for(producer_class.topic).produce_many_async(messages)
end

.shutdown_producer ⇒ void

This method returns an undefined value.

Shut down the producer cleanly.

# File 'sig/defs.rbs', line 287

def self.shutdown_producer: () -> void