diff --git a/heartbeat/monitors/factory.go b/heartbeat/monitors/factory.go
index c71103c083b..78d5aa64809 100644
--- a/heartbeat/monitors/factory.go
+++ b/heartbeat/monitors/factory.go
@@ -120,6 +120,10 @@ func newCommonPublishConfigs(info beat.Info, cfg *common.Config) (pipetool.Confi
 		fields := clientCfg.Processing.Fields.Clone()
 		fields.Put("event.dataset", dataset)
 
+		if settings.DataStream != nil {
+			fields.Put("data_stream", settings.DataStream)
+		}
+
 		meta := clientCfg.Processing.Meta.Clone()
 		if settings.Pipeline != "" {
 			meta.Put("pipeline", settings.Pipeline)