Fix Syntax

Signed-off-by: Mahad Zaryab <mahadzaryab1@gmail.com>
jaegertracing · Sep 29, 2024 · 7be814a · 7be814a
1 parent 93e45b9
commit 7be814a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 5 deletions.
diff --git a/cmd/jaeger/config-kafka-collector.yaml b/cmd/jaeger/config-kafka-collector.yaml
@@ -35,5 +35,5 @@ exporters:
   kafka:
     brokers:
       - localhost:9092
-    topic: env:KAFKA_TOPIC:-jaeger-spans
-    encoding: env:KAFKA_ENCODING:-otlp_proto
+    topic: ${env:KAFKA_TOPIC:-jaeger-spans}
+    encoding: ${env:KAFKA_ENCODING:-otlp_proto}
diff --git a/cmd/jaeger/config-kafka-ingester.yaml b/cmd/jaeger/config-kafka-ingester.yaml
@@ -32,8 +32,8 @@ receivers:
   kafka:
     brokers:
       - localhost:9092
-    topic: env:KAFKA_TOPIC:-jaeger-spans
-    encoding: env:KAFKA_ENCODING:-otlp_proto
+    topic: ${env:KAFKA_TOPIC:-jaeger-spans}
+    encoding: ${env:KAFKA_ENCODING:-otlp_proto}
     initial_offset: earliest
 
 processors:

diff --git a/cmd/jaeger/internal/integration/kafka_test.go b/cmd/jaeger/internal/integration/kafka_test.go
@@ -37,7 +37,10 @@ func TestKafkaStorage(t *testing.T) {
 			// has access to the storage and allows the test to query it.
 			// We reuse E2EStorageIntegration struct to manage lifecycle of the collector,
 			// but the tests are run against the ingester.
-			envVarOverrides := map[string]string{"KAFKA_TOPIC": uniqueTopic, "KAFKA_ENCODING": test.encoding}
+			envVarOverrides := map[string]string{
+				"KAFKA_TOPIC":    uniqueTopic,
+				"KAFKA_ENCODING": test.encoding,
+			}
 
 			collector := &E2EStorageIntegration{
 				BinaryName:         "jaeger-v2-collector",