Method: Fluent::Kafka2Output#wait_writing_threads

Defined in:
lib/fluent/plugin/out_kafka2.rb

#wait_writing_threads ⇒ Object 



258
259
260
261
262
263
264
265
266
 
# File 'lib/fluent/plugin/out_kafka2.rb', line 258

def wait_writing_threads
  done = false
  until done do
    @writing_threads_mutex.synchronize do
      done = true if @writing_threads.empty?
    end
    sleep(1) unless done
  end
end