Fix throwing exception when tracing protocol is not grpc

Adjust exception message for unsupported tracing exporter protocols Add test for unsupported otlp exporter protocol config
quarkusio · Oct 11, 2023 · 7b5f270 · 7b5f270
1 parent cca68dd
commit 7b5f270
Show file tree

Hide file tree

Showing 4 changed files with 55 additions and 5 deletions.
diff --git a/...c/test/java/io/quarkus/opentelemetry/deployment/exporter/otlp/OtlpExporterConfigTest.java b/...c/test/java/io/quarkus/opentelemetry/deployment/exporter/otlp/OtlpExporterConfigTest.java
@@ -16,7 +16,7 @@ public class OtlpExporterConfigTest {
     static final QuarkusUnitTest TEST = new QuarkusUnitTest()
             .withEmptyApplication()
             .overrideConfigKey("otel.traces.exporter", "cdi")
-            .overrideConfigKey("otel.exporter.otlp.traces.protocol", "http/protobuf")
+            .overrideConfigKey("otel.exporter.otlp.traces.protocol", "grpc")
             .overrideConfigKey("quarkus.opentelemetry.tracer.exporter.otlp.endpoint", "http://localhost ")
             .overrideConfigKey("quarkus.otel.bsp.schedule.delay", "50")
             .overrideConfigKey("quarkus.otel.bsp.export.timeout", "1s");

diff --git a/...o/quarkus/opentelemetry/deployment/exporter/otlp/OtlpExporterUnsupportedProtocolTest.java b/...o/quarkus/opentelemetry/deployment/exporter/otlp/OtlpExporterUnsupportedProtocolTest.java
@@ -0,0 +1,47 @@
+package io.quarkus.opentelemetry.deployment.exporter.otlp;
+
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.quarkus.test.QuarkusUnitTest;
+
+public class OtlpExporterUnsupportedProtocolTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest TEST = new QuarkusUnitTest()
+            .withEmptyApplication()
+            .overrideConfigKey("otel.traces.exporter", "cdi")
+            .overrideConfigKey("quarkus.otel.exporter.otlp.traces.protocol", "http/protobuf")
+            .overrideConfigKey("quarkus.opentelemetry.tracer.exporter.otlp.endpoint", "http://localhost ")
+            .overrideConfigKey("quarkus.otel.bsp.schedule.delay", "50")
+            .overrideConfigKey("quarkus.otel.bsp.export.timeout", "1s")
+            .assertException(t -> {
+                Throwable e = t;
+                IllegalStateException ie = null;
+                while (e != null) {
+                    if (t instanceof IllegalStateException) {
+                        ie = (IllegalStateException) t;
+                        break;
+                    }
+                    e = e.getCause();
+                }
+
+                if (ie == null) {
+                    fail("No IllegalStateException thrown: " + t);
+                }
+                assertTrue(ie.getMessage().contains("Only the `grpc` protocol is currently supported."),
+                        ie.getMessage());
+                assertTrue(ie.getMessage().contains("`http/protobuf` is available after Quarkus 3.3."),
+                        ie.getMessage());
+                assertTrue(ie.getMessage().contains("Please check `otel.exporter.otlp.traces.protocol` property"),
+                        ie.getMessage());
+            });
+
+    @Test
+    void testNotSupportedProtocolConfig() {
+        fail();
+    }
+}
diff --git a/...va/io/quarkus/opentelemetry/runtime/config/runtime/exporter/OtlpExporterTracesConfig.java b/...va/io/quarkus/opentelemetry/runtime/config/runtime/exporter/OtlpExporterTracesConfig.java
@@ -69,8 +69,10 @@ public interface OtlpExporterTracesConfig {
     /**
      * OTLP defines the encoding of telemetry data and the protocol used to exchange data between the client and the
      * server. Depending on the exporter, the available protocols will be different.
+     * <p>
+     * Currently, only {@code grpc} is allowed.
      */
-    @WithDefault(Protocol.HTTP_PROTOBUF)
+    @WithDefault(Protocol.GRPC)
     Optional<String> protocol();
 
     public static class Protocol {

diff --git a/...ry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/exporter/otlp/OtlpRecorder.java b/...ry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/exporter/otlp/OtlpRecorder.java
@@ -2,7 +2,7 @@
 
 import static io.quarkus.opentelemetry.runtime.OpenTelemetryUtil.convertKeyValueListToMap;
 import static io.quarkus.opentelemetry.runtime.config.runtime.exporter.OtlpExporterRuntimeConfig.DEFAULT_GRPC_BASE_URI;
-import static io.quarkus.opentelemetry.runtime.config.runtime.exporter.OtlpExporterTracesConfig.Protocol.HTTP_PROTOBUF;
+import static io.quarkus.opentelemetry.runtime.config.runtime.exporter.OtlpExporterTracesConfig.Protocol.GRPC;
 
 import java.util.List;
 import java.util.Map;
@@ -106,8 +106,9 @@ public void accept(CompressionType compression) {
                     }
                 });
 
-        if (!exporterRuntimeConfig.traces().protocol().orElse("").equals(HTTP_PROTOBUF)) {
-            throw new IllegalStateException("Only the GRPC Exporter is currently supported. " +
+        if (!exporterRuntimeConfig.traces().protocol().orElse("").equals(GRPC)) {
+            throw new IllegalStateException("Only the `grpc` protocol is currently supported. " +
+                    "`http/protobuf` is available after Quarkus 3.3. " +
                     "Please check `otel.exporter.otlp.traces.protocol` property");
         }
         return exporterBuilder.build();