Try otel logging emitting.

Author: kannanjgithub

interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java

@@ -269,7 +269,7 @@ private void run() {
           .enableTracing()
           .sdk(AutoConfiguredOpenTelemetrySdk.builder()
               .addPropertiesSupplier(() -> ImmutableMap.of(
-                  "otel.logs.exporter", "none",
+                  "otel.logs.exporter", "otlp",
                   "otel.metrics.exporter", "prometheus",
                   "otel.traces.exporter", "otlp",
                   "otel.exporter.otlp.endpoint", "https://telemetry.googleapis.com",

interop-testing/src/main/java/io/grpc/testing/integration/XdsTestServer.java

@@ -201,7 +201,7 @@ void start() throws Exception {
           .enableTracing()
           .sdk(AutoConfiguredOpenTelemetrySdk.builder()
               .addPropertiesSupplier(() -> ImmutableMap.of(
-                  "otel.logs.exporter", "none",
+                  "otel.logs.exporter", "otlp",
                   "otel.metrics.exporter", "prometheus",
                   "otel.traces.exporter", "otlp",
                   "otel.exporter.otlp.endpoint", "https://telemetry.googleapis.com",

opentelemetry/src/main/java/io/grpc/opentelemetry/GrpcOpenTelemetry.java

@@ -87,6 +87,9 @@ public static Builder newBuilder() {
 
   private GrpcOpenTelemetry(Builder builder) {
     this.openTelemetrySdk = checkNotNull(builder.openTelemetrySdk, "openTelemetrySdk");
+    openTelemetrySdk.getLogsBridge().loggerBuilder("my-instrumentation-scope")
+        .setInstrumentationVersion("1.0.0")
+        .build();
     this.meterProvider = checkNotNull(openTelemetrySdk.getMeterProvider(), "meterProvider");
     this.meter = this.meterProvider
         .meterBuilder(OpenTelemetryConstants.INSTRUMENTATION_SCOPE)

opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java

@@ -42,6 +42,7 @@
 import io.opentelemetry.api.OpenTelemetry;
 import io.opentelemetry.api.baggage.Baggage;
 import io.opentelemetry.api.common.AttributesBuilder;
+import io.opentelemetry.api.logs.Severity;
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.api.trace.StatusCode;
 import io.opentelemetry.api.trace.Tracer;
@@ -68,7 +69,7 @@ final class OpenTelemetryTracingModule {
   private static final AtomicIntegerFieldUpdater<ServerTracer> streamClosedUpdater;
 
   /*
-   * When using Atomic*FieldUpdater, some Samsung Android 5.0.x devices encounter a bug in their JDK
+   * When using Atomic*FieldUpdater, some Samsung Android 5.0.x devices encounter a bug in their JDKimport io.opentelemetry.api.logs.Severity;logsb
    * reflection API that triggers a NoSuchFieldException. When this occurs, we fallback to
    * (potentially racy) direct updates of the volatile variables.
    */
@@ -97,13 +98,17 @@ final class OpenTelemetryTracingModule {
   private final ServerInterceptor serverSpanPropagationInterceptor =
       new TracingServerSpanPropagationInterceptor();
   private final ServerTracerFactory serverTracerFactory = new ServerTracerFactory();
+  private final io.opentelemetry.api.logs.Logger otelLogger;
 
   OpenTelemetryTracingModule(OpenTelemetry openTelemetry) {
     this.otelTracer = checkNotNull(openTelemetry.getTracerProvider(), "tracerProvider")
         .tracerBuilder(OpenTelemetryConstants.INSTRUMENTATION_SCOPE)
         .setInstrumentationVersion(IMPLEMENTATION_VERSION)
         .build();
     this.contextPropagators = checkNotNull(openTelemetry.getPropagators(), "contextPropagators");
+    this.otelLogger = openTelemetry.getLogsBridge().loggerBuilder("grpc-java-client-scope")
+        .setInstrumentationVersion("1.0.0")
+        .build();
   }
 
   @VisibleForTesting
@@ -116,7 +121,7 @@ Tracer getTracer() {
    */
   @VisibleForTesting
   CallAttemptsTracerFactory newClientCallTracer(Span clientSpan, MethodDescriptor<?, ?> method) {
-    return new CallAttemptsTracerFactory(clientSpan, method);
+    return new CallAttemptsTracerFactory(clientSpan, method, otelLogger);
   }
 
   /**
@@ -142,11 +147,14 @@ final class CallAttemptsTracerFactory extends ClientStreamTracer.Factory {
     volatile int callEnded;
     private final Span clientSpan;
     private final String fullMethodName;
+    private final io.opentelemetry.api.logs.Logger otelLogger;
 
-    CallAttemptsTracerFactory(Span clientSpan, MethodDescriptor<?, ?> method) {
+    CallAttemptsTracerFactory(Span clientSpan, MethodDescriptor<?, ?> method,
+        io.opentelemetry.api.logs.Logger otelLogger) {
       checkNotNull(method, "method");
       this.fullMethodName = checkNotNull(method.getFullMethodName(), "fullMethodName");
       this.clientSpan = checkNotNull(clientSpan, "clientSpan");
+      this.otelLogger = otelLogger;
     }
 
     @Override
@@ -464,6 +472,11 @@ private void recordOutboundMessageSentEvent(Span span,
       attributesBuilder.put("message-size-compressed", optionalWireSize);
     }
     span.addEvent("Outbound message", attributesBuilder.build());
+    otelLogger.logRecordBuilder().setSeverity(Severity.INFO)
+        .setSeverityText("INFO")
+        .setBody("outbound message event") // The main message body
+        .setAllAttributes(attributesBuilder.build())
+        .emit();
   }
 
   private void recordInboundCompressedMessage(Span span, int seqNo, long optionalWireSize) {