From bea255ab113f631d3bf1d33add36dc7a0e2ef046 Mon Sep 17 00:00:00 2001 From: Alexandr Korsak Date: Thu, 1 Dec 2016 16:46:18 +0300 Subject: [PATCH] Register kafka output plugin in case of having passed settings --- plugins.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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) + } }