Class: Deimos::Backends::Kafka

Inherits:

Base

• Object
• Base
• Deimos::Backends::Kafka

Includes:

Phobos::Producer

Defined in:

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

Overview

Default backend to produce to Kafka.

Class Method Summary

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

  :nodoc:.

• .shutdown_producer ⇒ void

  Shut down the producer if necessary.

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.rb', line 8

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

.shutdown_producer ⇒ void

This method returns an undefined value.

Shut down the producer if necessary.

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

def self.shutdown_producer: () -> void