Class: Deimos::Backends::KafkaAsync

Inherits:

Base

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

Defined in:

lib/deimos/backends/kafka_async.rb

Overview

Backend which produces to Kafka via an async producer.

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

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