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