Use IndexPrefix for kafka and logstash output.

Output index differed to Elasticsearch output. fixes elastic#10839
simitt · Feb 25, 2019 · 210ce7e · 210ce7e
1 parent 59a05ed
commit 210ce7e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/libbeat/outputs/kafka/kafka.go b/libbeat/outputs/kafka/kafka.go
@@ -107,7 +107,7 @@ func makeKafka(
 		return outputs.Fail(err)
 	}
 
-	client, err := newKafkaClient(observer, hosts, beat.Beat, config.Key, topic, codec, libCfg)
+	client, err := newKafkaClient(observer, hosts, beat.IndexPrefix, config.Key, topic, codec, libCfg)
 	if err != nil {
 		return outputs.Fail(err)
 	}

diff --git a/libbeat/outputs/logstash/logstash.go b/libbeat/outputs/logstash/logstash.go
@@ -46,7 +46,7 @@ func makeLogstash(
 	cfg *common.Config,
 ) (outputs.Group, error) {
 	if !cfg.HasField("index") {
-		cfg.SetString("index", -1, beat.Beat)
+		cfg.SetString("index", -1, beat.IndexPrefix)
 	}
 
 	err := cfgwarn.CheckRemoved6xSettings(cfg, "port")