test: Add integration test for include_file_owner_name and include_file_owner_group_name

Author: Hiruma31

filebeat/tests/integration/filestream_test.go

@@ -678,6 +678,50 @@ func TestFilestreamTakeOverFromLogInput(t *testing.T) {
 	}
 }
 
+func TestFilestreamHasOwnerAndGroup(t *testing.T) {
+	cfg := `
+filebeat.inputs:
+  - type: filestream
+    enabled: true
+    paths:
+      - /var/log/*.log
+	include_file_owner_name: true
+	include_file_owner_group_name: true
+
+output.discard.enabled: true
+logging:
+  level: debug
+  metrics:
+    enabled: false
+`
+	filebeat := integration.NewBeat(
+		t,
+		"filebeat",
+		"../../filebeat.test",
+	)
+
+	// Write configuration file and start Filebeat
+	filebeat.WriteConfigFile(cfg)
+	filebeat.Start()
+
+	// Wait for log
+	filebeat.WaitPublishedEvents(20*time.Second, 5)
+	type evt struct {
+		Message string `json:"message"`
+	}
+
+	evts := integration.GetEventsFromFileOutput[evt](filebeat, 5, false)
+	for i, e := range evts {
+		owner, err := e.Fields.GetValue("log.file.owner")
+		require.NoError(t, err, "event %d: could not get owner field", i)
+		require.NotEmpty(t, owner, "event %d: owner field is empty", i)
+
+		group, err := e.Fields.GetValue("log.file.group")
+		require.NoError(t, err, "event %d: could not get group field", i)
+		require.NotEmpty(t, group, "event %d: group field is empty", i)
+	}
+}
+
 // getConfig renders the template in testdata/<folder>/<tmplPath> using vars
 func getConfig(t *testing.T, vars map[string]any, folder, tmplPath string) string {
 	t.Helper()