Class: Deimos::Backends::Kafka

Inherits:

Base

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

Defined in:

lib/deimos/backends/kafka.rb

Overview

Default backend to produce to Kafka.

Class Method Summary

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

  :nodoc:.

Methods inherited from Base

publish

Class Method Details

.execute(producer_class:, messages:) ⇒ Object

:nodoc:

# 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