github/goreplay
4
0
Fork 0
mirror of https://github.com/buger/goreplay.git synced 2024-04-21 12:32:02 +00:00
Code Issues Releases Wiki Activity

Merge pull request #398 from oivoodoo/master

Browse Source 
Register kafka output plugin in case of having passed settings
This commit is contained in:
Leonid Bugaev
2016-12-02 18:02:49 +03:00
committed by GitHub
parent bde2977268 bea255ab11
commit ca61e39790
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins.go
+3 -1
View File
@@ -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)
}
}