From fa27bc832ff7a9370bd809def296b8965830a6cf Mon Sep 17 00:00:00 2001
From: jerop <jerop@google.com>
Date: Tue, 10 Jun 2025 21:23:35 +0000
Subject: [PATCH] feat: enable gzip compression for otlp exporters

---
 packages/core/src/telemetry/sdk.ts | 16 +++++++++++++---
 1 file changed, 13 insertions(+), 3 deletions(-)

diff --git a/packages/core/src/telemetry/sdk.ts b/packages/core/src/telemetry/sdk.ts
index 65d4ae68..8cd20b7b 100644
--- a/packages/core/src/telemetry/sdk.ts
+++ b/packages/core/src/telemetry/sdk.ts
@@ -8,6 +8,7 @@ import { DiagConsoleLogger, DiagLogLevel, diag } from '@opentelemetry/api';
 import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-grpc';
 import { OTLPLogExporter } from '@opentelemetry/exporter-logs-otlp-grpc';
 import { OTLPMetricExporter } from '@opentelemetry/exporter-metrics-otlp-grpc';
+import { CompressionAlgorithm } from '@opentelemetry/otlp-exporter-base';
 import { NodeSDK } from '@opentelemetry/sdk-node';
 import { SemanticResourceAttributes } from '@opentelemetry/semantic-conventions';
 import { Resource } from '@opentelemetry/resources';
@@ -75,14 +76,23 @@ export function initializeTelemetry(config: Config): void {
   const useOtlp = !!grpcParsedEndpoint;
 
   const spanExporter = useOtlp
-    ? new OTLPTraceExporter({ url: grpcParsedEndpoint })
+    ? new OTLPTraceExporter({
+        url: grpcParsedEndpoint,
+        compression: CompressionAlgorithm.GZIP,
+      })
     : new ConsoleSpanExporter();
   const logExporter = useOtlp
-    ? new OTLPLogExporter({ url: grpcParsedEndpoint })
+    ? new OTLPLogExporter({
+        url: grpcParsedEndpoint,
+        compression: CompressionAlgorithm.GZIP,
+      })
     : new ConsoleLogRecordExporter();
   const metricReader = useOtlp
     ? new PeriodicExportingMetricReader({
-        exporter: new OTLPMetricExporter({ url: grpcParsedEndpoint }),
+        exporter: new OTLPMetricExporter({
+          url: grpcParsedEndpoint,
+          compression: CompressionAlgorithm.GZIP,
+        }),
         exportIntervalMillis: 10000,
       })
     : new PeriodicExportingMetricReader({