lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.15.0 vs lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.15.1

- old
+ new

@@ -126,10 +126,10 @@ if @brokers.size > 0 @seed_brokers = @brokers log.info "brokers has been set: #{@seed_brokers}" else - raise Fluent::Config, 'No brokers specified. Need one broker at least.' + raise Fluent::ConfigError, 'No brokers specified. Need one broker at least.' end formatter_conf = conf.elements('format').first unless formatter_conf raise Fluent::ConfigError, "<format> section is required."