Micronaut服务迁移：Micrometer与OpenTelemetry集成及线程传播问题

一、Micrometer与OpenTelemetry的集成配置 #

是的，你需要添加Micrometer OpenTelemetry Bridge来实现Micrometer指标向OpenTelemetry的转换，进而通过OTLP Exporter发送到Datadog。在Micronaut中可通过以下步骤配置：

1. 添加依赖

   • Gradle：

     implementation 'io.micrometer:micrometer-registry-otel'
     implementation 'io.micrometer:micrometer-tracing-bridge-otel'
     

   • Maven：

     <dependency>
         <groupId>io.micrometer</groupId>
         <artifactId>micrometer-registry-otel</artifactId>
     </dependency>
     <dependency>
         <groupId>io.micrometer</groupId>
         <artifactId>micrometer-tracing-bridge-otel</artifactId>
     </dependency>
     

2. 配置OTLP导出
   在application.yml或application.properties中开启并配置OTLP exporter：

micrometer:
  export:
    otel:
      enabled: true
      url: "http://your-otlp-collector:4318/v1/metrics"
      headers:
        "X-Datadog-Api-Key": "your-datadog-api-key"
otel:
  traces:
    exporter: otlp
  metrics:
    exporter: otlp

配置完成后，Micrometer的指标会自动桥接到OpenTelemetry，通过OTLP统一发送至Datadog。

二、Executor服务的追踪上下文传播 #

Micronaut框架内置的Executor服务（如ManagedExecutorService、通过TaskExecutors获取的执行器）已经默认实现了追踪上下文的自动传播，无需手动包装。这些执行器会自动将当前线程的OpenTelemetry上下文附加到异步任务中，保证追踪链路的完整性。

但如果你使用自定义的Executor实例（比如手动创建的ThreadPoolExecutor），则需要使用OpenTelemetry的工具类包装任务：

// 注入OpenTelemetry实例
@Inject
OpenTelemetry openTelemetry;

// 包装Runnable
Runnable tracedRunnable = Context.current().wrap(yourRunnable);
// 包装Callable
Callable<?> tracedCallable = Context.current().wrap(yourCallable);

将包装后的任务提交给自定义Executor，即可实现上下文传播。

内容的提问来源于stack exchange，提问作者Javier Toja