diff --git a/beater/kafkabeat.go b/beater/kafkabeat.go
index 19f705b9..40aa51d2 100644
--- a/beater/kafkabeat.go
+++ b/beater/kafkabeat.go
@@ -13,7 +13,7 @@ import (
 	"github.com/elastic/beats/libbeat/beat"
 	"github.com/elastic/beats/libbeat/common"
 	"github.com/elastic/beats/libbeat/logp"
-	)
+)
 
 type msgDecodeFn func(msg *sarama.ConsumerMessage) *beat.Event