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