Java

import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.logs.Logger;
import io.opentelemetry.api.logs.Severity;
import io.opentelemetry.api.trace.Span;
import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.context.Scope;
import io.opentelemetry.exporter.otlp.logs.OtlpGrpcLogRecordExporter;
import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.logs.SdkLoggerProvider;
import io.opentelemetry.sdk.logs.export.BatchLogRecordProcessor;
import io.opentelemetry.sdk.resources.Resource;
import io.opentelemetry.sdk.trace.SdkTracerProvider;
import java.time.Instant;
import java.util.concurrent.TimeUnit;

public class Main {
  private static String envOrDefault(String key, String fallback) {
    String value = System.getenv(key);
    return value == null || value.isBlank() ? fallback : value;
  }

  public static void main(String[] args) throws Exception {
    String endpoint = envOrDefault("OTEL_EXPORTER_OTLP_ENDPOINT", "http://host.docker.internal:4317");
    String serviceName = envOrDefault("OTEL_SERVICE_NAME", "java-otel-logs-sample");
    String applicationName = envOrDefault("CORALOGIX_APPLICATION", "java-otel-app");
    String subsystemName = envOrDefault("CORALOGIX_SUBSYSTEM", "worker");

    Resource resource = Resource.getDefault().merge(
        Resource.create(Attributes.of(
            AttributeKey.stringKey("service.name"), serviceName,
            AttributeKey.stringKey("cx.application.name"), applicationName,
            AttributeKey.stringKey("cx.subsystem.name"), subsystemName
        ))
    );

    OtlpGrpcLogRecordExporter logExporter = OtlpGrpcLogRecordExporter.builder()
        .setEndpoint(endpoint)
        .build();

    SdkLoggerProvider loggerProvider =
        SdkLoggerProvider.builder()
            .setResource(resource)
            .addLogRecordProcessor(BatchLogRecordProcessor.builder(logExporter).build())
            .build();

    SdkTracerProvider tracerProvider = SdkTracerProvider.builder()
            .setResource(resource)
            .build();

    OpenTelemetrySdk openTelemetry =
        OpenTelemetrySdk.builder()
            .setLoggerProvider(loggerProvider)
            .setTracerProvider(tracerProvider)
            .buildAndRegisterGlobal();

    Logger logger = GlobalOpenTelemetry.get().getLogsBridge().loggerBuilder("My class").build();
    Tracer tracer = openTelemetry.getTracer("java-otel-example");

    System.out.printf("OTLP logs endpoint: %s%n", endpoint);

    logger.logRecordBuilder()
        .setTimestamp(Instant.now())
        .setSeverity(Severity.INFO)
        .setBody("hello java logging with OpenTelemetry")
        .emit();

    Span span = tracer.spanBuilder("manual-span").startSpan();
    try (Scope ignored = span.makeCurrent()) {
      logger.logRecordBuilder()
          .setTimestamp(Instant.now())
          .setSeverity(Severity.WARN)
          .setBody("java log with trace correlation")
          .emit();
    } finally {
      span.end();
    }

    for (int i = 0; i < 10; i++) {
      var builder = logger.logRecordBuilder()
          .setTimestamp(Instant.now())
          .setSeverity(Severity.ERROR)
          .setBody("Hello World Coralogix");
      builder.emit();
      Thread.sleep(1000);
    }

    Thread.sleep(1500);
    loggerProvider.forceFlush().join(10, TimeUnit.SECONDS);
    loggerProvider.shutdown().join(10, TimeUnit.SECONDS);
    tracerProvider.shutdown().join(10, TimeUnit.SECONDS);

    System.out.println("Done: flush + shutdown completed");
  }
}