Fix field not being added

elastic · Aug 20, 2020 · 748739b · 748739b
1 parent 4c5d741
commit 748739b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/heartbeat/monitors/factory.go b/heartbeat/monitors/factory.go
@@ -23,6 +23,7 @@ import (
 	"github.com/elastic/beats/v7/libbeat/cfgfile"
 	"github.com/elastic/beats/v7/libbeat/common"
 	"github.com/elastic/beats/v7/libbeat/common/fmtstr"
+	"github.com/elastic/beats/v7/libbeat/logp"
 	"github.com/elastic/beats/v7/libbeat/processors"
 	"github.com/elastic/beats/v7/libbeat/processors/add_formatted_index"
 	"github.com/elastic/beats/v7/libbeat/publisher/pipetool"
@@ -104,6 +105,8 @@ func newCommonPublishConfigs(info beat.Info, cfg *common.Config) (pipetool.Confi
 	}
 
 	return func(clientCfg beat.ClientConfig) (beat.ClientConfig, error) {
+		logp.Info("Client connection with: %#v", clientCfg)
+
 		fields := clientCfg.Processing.Fields.Clone()
 		fields.Put("event.dataset", dataset)
 
@@ -128,6 +131,7 @@ func newCommonPublishConfigs(info beat.Info, cfg *common.Config) (pipetool.Confi
 		}
 
 		clientCfg.Processing.EventMetadata = settings.EventMetadata
+		clientCfg.Processing.Fields = fields
 		clientCfg.Processing.Meta = meta
 		clientCfg.Processing.Processor = procs
 		clientCfg.Processing.KeepNull = settings.KeepNull