lib/kafka/async_producer.rb
# Shuts down the producer, releasing the network resources used. This
# method will block until the buffered messages have been delivered.
#
# @see Kafka::Producer#shutdown
# @return [nil]
Shuts down the producer, releasing the network resources used. This
method will block until the buffered messages have been delivered.
Shuts down the producer releasing the network resources used . This method will block until the buffered messages have been delivered .
def shutdown
      ensure_threads_running!
      @timer_thread && @timer_thread.exit
      @queue << [:shutdown, nil]
      @worker_thread && @worker_thread.join
      nil
    end
def shutdown ensure_threads_running! @timer_thread && @timer_thread . exit @queue << [ :shutdown , nil ] @worker_thread && @worker_thread . join nil end
Shuts down the producer, releasing the network resources used.
Shuts down the producer releasing the network resources used .
None
nil
see
None