From 210ce7eee7d962c3db5fc23787daaddc65a292a1 Mon Sep 17 00:00:00 2001 From: simitt Date: Wed, 20 Feb 2019 11:20:02 +0100 Subject: [PATCH] Use IndexPrefix for kafka and logstash output. Output index differed to Elasticsearch output. fixes #10839 --- libbeat/outputs/kafka/kafka.go | 2 +- libbeat/outputs/logstash/logstash.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/libbeat/outputs/kafka/kafka.go b/libbeat/outputs/kafka/kafka.go index dc34e77c558..6b27013ff41 100644 --- 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 index 0c14bf5882b..b62c75e8b62 100644 --- 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")