SROTEL-428 - LogRecordExporter is created using incorrect service name (

#429) Add constant for log service name Update LogRecordExporter creation to use correct service name
smallrye · Jan 2, 2025 · c2d5de9 · c2d5de9
1 parent 6b2dfa6
commit c2d5de9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...va/io/smallrye/opentelemetry/implementation/exporters/logs/VertxLogsExporterProvider.java b/...va/io/smallrye/opentelemetry/implementation/exporters/logs/VertxLogsExporterProvider.java
@@ -26,7 +26,7 @@ public LogRecordExporter createExporter(ConfigProperties config) {
             final String protocol = getProtocol(config, getSignalType());
 
             if (PROTOCOL_GRPC.equals(protocol)) {
-                return new VertxGrpcLogsExporter(createGrpcExporter(config, VertxGrpcSender.GRPC_TRACE_SERVICE_NAME));
+                return new VertxGrpcLogsExporter(createGrpcExporter(config, VertxGrpcSender.GRPC_LOG_SERVICE_NAME));
             } else if (PROTOCOL_HTTP_PROTOBUF.equals(protocol)) {
                 return new VertxHttpLogsExporter(createHttpExporter(config, VertxHttpSender.LOGS_PATH));
             } else {

diff --git a/.../main/java/io/smallrye/opentelemetry/implementation/exporters/sender/VertxGrpcSender.java b/.../main/java/io/smallrye/opentelemetry/implementation/exporters/sender/VertxGrpcSender.java
@@ -40,6 +40,7 @@ public final class VertxGrpcSender<T extends Marshaler> implements GrpcSender<T>
 
     public static final String GRPC_TRACE_SERVICE_NAME = "opentelemetry.proto.collector.trace.v1.TraceService";
     public static final String GRPC_METRIC_SERVICE_NAME = "opentelemetry.proto.collector.metrics.v1.MetricsService";
+    public static final String GRPC_LOG_SERVICE_NAME = "opentelemetry.proto.collector.logs.v1.LogsService";
     private static final String GRPC_METHOD_NAME = "Export";
 
     private static final String GRPC_STATUS = "grpc-status";