keep a single test as suggested

Author: mauri870

x-pack/filebeat/tests/integration/otel_kafka_test.go

@@ -34,92 +34,6 @@ func TestFilebeatOTelKafkaExporter(t *testing.T) {
 
 	otelCfg := fmt.Sprintf(`receivers:
   filebeatreceiver:
-    filebeat:
-      inputs:
-        - type: filestream
-          id: filestream-input-id
-          enabled: true
-          paths:
-            - %s
-          prospector.scanner.fingerprint.enabled: false
-          file_identity.native: ~
-    queue.mem.flush.timeout: 0s
-    setup.template.enabled: false
-    path.home: %s
-exporters:
-  kafka:
-    brokers:
-      - %s
-    logs:
-      topic: %s
-      encoding: raw
-service:
-  pipelines:
-    logs:
-      receivers:
-        - filebeatreceiver
-      exporters:
-        - kafka
-  telemetry:
-    metrics:
-      level: none
-`, logFilePath, tmpdir, kafkaBroker, topic)
-
-	oteltestcol.New(t, otelCfg)
-
-	received := consumeKafkaTopic(t, topic)
-
-	t.Logf("received Kafka message: %s", string(received))
-
-	var body mapstr.M
-	require.NoError(t, json.Unmarshal(received, &body), "Kafka message is not valid JSON")
-	got := body.Flatten()
-
-	// Check non-deterministic fields are present.
-	agentVersion, _ := got.GetValue("agent.version")
-	require.NotEmpty(t, agentVersion, "expected agent.version to be set")
-	agentID, _ := got.GetValue("agent.id")
-	require.NotEmpty(t, agentID, "expected agent.id to be set")
-	agentEphemeralID, _ := got.GetValue("agent.ephemeral_id")
-	require.NotEmpty(t, agentEphemeralID, "expected agent.ephemeral_id to be set")
-	hostName, _ := got.GetValue("host.name")
-	require.NotEmpty(t, hostName, "expected host.name to be set")
-	timestamp, _ := got.GetValue("@timestamp")
-	require.NotEmpty(t, timestamp, "expected @timestamp to be set")
-
-	// Remove non-deterministic fields before comparison.
-	_ = got.Delete("@timestamp")
-	_ = got.Delete("agent.id")
-	_ = got.Delete("agent.ephemeral_id")
-	_ = got.Delete("agent.name")
-	_ = got.Delete("agent.version")
-	_ = got.Delete("host.name")
-	_ = got.Delete("log.file.device_id")
-	_ = got.Delete("log.file.inode")
-
-	want := mapstr.M{
-		"message":       "Line 0",
-		"agent.type":    "filebeat",
-		"input.type":    "filestream",
-		"ecs.version":   "8.0.0",
-		"log.offset":    float64(0),
-		"log.file.path": logFilePath,
-	}
-
-	if diff := cmp.Diff(want, got); diff != "" {
-		t.Fatalf("log event fields mismatch (-want +got):\n%s", diff)
-	}
-}
-
-func TestFilebeatOTelKafkaExporterIncludesMetadata(t *testing.T) {
-	topic := fmt.Sprintf("test-otel-kafka-meta-%s", uuid.Must(uuid.NewV4()).String())
-
-	tmpdir := t.TempDir()
-	logFilePath := filepath.Join(tmpdir, "kafka_test.log")
-	writeEventsToLogFile(t, logFilePath, 1)
-
-	otelCfg := fmt.Sprintf(`receivers:
-  filebeatreceiver:
     include_metadata: true
     filebeat:
       inputs: