lib/deimos/backends/kafka_async.rb in deimos-ruby-1.16.3 vs lib/deimos/backends/kafka_async.rb in deimos-ruby-1.16.4

- old
+ new

@@ -5,9 +5,10 @@ # Backend which produces to Kafka via an async producer. class KafkaAsync < Base include Phobos::Producer # Shut down the producer cleanly. + # @return [void] def self.shutdown_producer producer.async_producer_shutdown producer.kafka_client&.close end