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(timeout = nil)
      ensure_threads_running!
      @queue.close
      @worker.flip_shutdown_latch!
      @timer_thread && @timer_thread.exit
      @worker_thread && @worker_thread.join(timeout)
      nil
    end
def shutdown ( timeout = nil ) ensure_threads_running! @queue . close @worker . flip_shutdown_latch! @timer_thread && @timer_thread . exit @worker_thread && @worker_thread . join ( timeout ) nil end
Shuts down the producer, releasing the network resources used.
Shuts down the producer releasing the network resources used .
None
nil
timeout
see
None