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