test/plugin/test_out_kafka.rb in fluent-plugin-kafka-0.6.3 vs test/plugin/test_out_kafka.rb in fluent-plugin-kafka-0.6.4

@@ -41,9 +41,15 @@
 
   def test_format
     d = create_driver
   end
 
+  def test_mutli_worker_support
+    d = create_driver
+    assert_equal true, d.instance.multi_workers_ready?
+
+  end
+
   def test_write
     d = create_driver
     time = Time.parse("2011-01-02 13:14:15 UTC").to_i
     d.emit({"a"=>1}, time)
     d.emit({"a"=>2}, time)