diff --git a/plugins.go b/plugins.go index a625f9b..6ee1516 100644 --- a/plugins.go +++ b/plugins.go @@ -143,5 +143,7 @@ func InitPlugins() { registerPlugin(NewHTTPOutput, options, &Settings.outputHTTPConfig) } - registerPlugin(NewKafkaOutput, "", &Settings.outputKafkaConfig) + if Settings.outputKafkaConfig.host != "" && Settings.outputKafkaConfig.topic != "" { + registerPlugin(NewKafkaOutput, "", &Settings.outputKafkaConfig) + } }