lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.7.0 vs lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.7.1

- old
+ new

@@ -99,10 +99,11 @@ def configure(conf) super if @brokers.size > 0 - log.info "brokers has been set: #{@brokers}" + @seed_brokers = @brokers + log.info "brokers has been set: #{@seed_brokers}" else raise Fluent::Config, 'No brokers specified. Need one broker at least.' end formatter_conf = conf.elements('format').first