class Deimos::Backends::Kafka

Default backend to produce to Kafka.

Public Class Methods

shutdown_producer() click to toggle source

Shut down the producer if necessary.

# File lib/deimos/backends/kafka.rb, line 10
def self.shutdown_producer
  producer.sync_producer_shutdown if producer.respond_to?(:sync_producer_shutdown)
  producer.kafka_client&.close
end