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