test/plugin/test_out_kafka2.rb in fluent-plugin-kafka-0.17.4 vs test/plugin/test_out_kafka2.rb in fluent-plugin-kafka-0.17.5

- old
+ new

@@ -58,9 +58,16 @@ def test_mutli_worker_support d = create_driver assert_equal true, d.instance.multi_workers_ready? end + def test_resolve_seed_brokers + d = create_driver(config + config_element('ROOT', '', {"resolve_seed_brokers" => true})) + assert_nothing_raised do + d.instance.refresh_client + end + end + class WriteTest < self TOPIC_NAME = "kafka-output-#{SecureRandom.uuid}" INPUT_CONFIG = %[ @type kafka