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