class Deimos::Backends::KafkaAsync

Backend which produces to Kafka via an async producer.

Public Class Methods

shutdown_producer() click to toggle source

Shut down the producer cleanly.

# File lib/deimos/backends/kafka_async.rb, line 10
def self.shutdown_producer
  producer.async_producer_shutdown
  producer.kafka_client&.close
end