Skip to content

Commit 81d6519

Browse files
committed
remove leftover comment
1 parent c7cabb1 commit 81d6519

1 file changed

Lines changed: 0 additions & 6 deletions

File tree

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

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,6 @@ service:
7171

7272
t.Logf("received Kafka message: %s", string(received))
7373

74-
// With raw encoding the message is the JSON-marshaled body map directly.
7574
var body mapstr.M
7675
require.NoError(t, json.Unmarshal(received, &body), "Kafka message is not valid JSON")
7776
got := body.Flatten()
@@ -112,10 +111,6 @@ service:
112111
}
113112
}
114113

115-
// TestFilebeatOTelKafkaExporterIncludesMetadata verifies that Beat event
116-
// metadata is preserved end-to-end through the OTel pipeline and
117-
// survives body-only encodings. With include_metadata enabled,
118-
// the @metadata field is persisted to the log record attribute.
119114
func TestFilebeatOTelKafkaExporterIncludesMetadata(t *testing.T) {
120115
topic := fmt.Sprintf("test-otel-kafka-meta-%s", uuid.Must(uuid.NewV4()).String())
121116

@@ -166,7 +161,6 @@ service:
166161

167162
t.Logf("received Kafka message: %s", string(received))
168163

169-
// With raw encoding the message is the JSON-marshaled body map directly.
170164
var body mapstr.M
171165
require.NoError(t, json.Unmarshal(received, &body), "Kafka message is not valid JSON")
172166
got := body.Flatten()

0 commit comments

Comments
 (0)