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."