Fix kafka log message printing (#1516)

elastic · Apr 28, 2016 · 9404abb · 9404abb
1 parent a4281c0
commit 9404abb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/CHANGELOG.asciidoc b/CHANGELOG.asciidoc
@@ -49,6 +49,7 @@ https://github.com/elastic/beats/compare/v5.0.0-alpha1...master[Check the HEAD d
 - Fix race when multiple outputs access the same event with logstash output manipulating event {issue}1410[1410] {pull}1428[1428]
 - Seed random number generator using crypto.rand package. {pull}1503{1503]
 - Fix beats hanging in -configtest {issue}1213[1213]
+- Fix kafka log message output {pull}1516[1516]
 
 *Packetbeat*
 

diff --git a/libbeat/outputs/kafka/log.go b/libbeat/outputs/kafka/log.go
@@ -5,13 +5,13 @@ import "github.com/elastic/beats/libbeat/logp"
 type kafkaLogger struct{}
 
 func (kafkaLogger) Print(v ...interface{}) {
-	logp.Warn("kafka message: %v", v)
+	logp.Warn("kafka message: %v", v...)
 }
 
 func (kafkaLogger) Printf(format string, v ...interface{}) {
-	logp.Warn(format, v)
+	logp.Warn(format, v...)
 }
 
 func (kafkaLogger) Println(v ...interface{}) {
-	logp.Warn("kafka message: %v", v)
+	logp.Warn("kafka message: %v", v...)
 }