OpenTelemetry Java下span exporter导出失败如何重试或捕获异常

• 开启重试开关：配置otel.exporter.otlp.traces.retry.enabled=true，该配置默认在新版OpenTelemetry Java SDK中已默认开启，旧版本需手动指定
• 可调整的重试相关配置项：
  • 最大重试次数：otel.exporter.otlp.traces.retry.max-attempts=5，默认值为5，可根据业务需求调整
  • 初始重试间隔：otel.exporter.otlp.traces.retry.initial-backoff=1s
  • 最大重试间隔：otel.exporter.otlp.traces.retry.max-backoff=5s
• 原生重试规则默认已包含UNAVAILABLE状态码的匹配，完全覆盖你遇到的报错场景，无需额外编码，直接通过环境变量、系统属性或者配置文件注入即可生效。

如果原生重试逻辑无法满足需求（比如需要自定义告警通知、特殊重试规则），可以自行封装默认的SpanExporter，嵌入自定义逻辑：

1. 实现自定义带重试的SpanExporter包装类：

import io.opentelemetry.sdk.trace.export.SpanExporter;
import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.common.CompletableResultCode;
import com.github.rholder.retry.*;
import java.util.Collection;
import java.util.concurrent.TimeUnit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class RetryableSpanExporter implements SpanExporter {
    private static final Logger log = LoggerFactory.getLogger(RetryableSpanExporter.class);
    private final SpanExporter delegate;
    private final Retryer<CompletableResultCode> retryer;

    public RetryableSpanExporter(SpanExporter delegate) {
        this.delegate = delegate;
        this.retryer = RetryerBuilder.<CompletableResultCode>newBuilder()
                // 导出结果失败时重试
                .retryIfResult(result -> !result.isSuccess())
                // UNAVAILABLE状态异常时重试
                .retryIfException(throwable -> throwable instanceof io.grpc.StatusRuntimeException 
                        && ((io.grpc.StatusRuntimeException) throwable).getStatus().getCode() == io.grpc.Status.Code.UNAVAILABLE)
                .withStopStrategy(StopStrategies.stopAfterAttempt(5))
                .withWaitStrategy(WaitStrategies.exponentialWait(1000, 5000, TimeUnit.MILLISECONDS))
                .build();
    }

    @Override
    public CompletableResultCode export(Collection<SpanData> spans) {
        try {
            return retryer.call(() -> {
                CompletableResultCode result = delegate.export(spans);
                result.join(3, TimeUnit.SECONDS);
                if (!result.isSuccess()) {
                    log.warn("Span导出失败，触发重试");
                }
                return result;
            });
        } catch (RetryException | InterruptedException e) {
            // 所有重试都失败后的自定义处理逻辑，可对接告警、自定义日志输出
            log.error("Span导出多次重试均失败，Collector可能不可用", e);
            return CompletableResultCode.ofFailure();
        }
    }

    @Override
    public CompletableResultCode flush() {
        return delegate.flush();
    }

    @Override
    public CompletableResultCode shutdown() {
        return delegate.shutdown();
    }
}

2. 注册自定义Exporter到自动配置链路：
   如果是Spring Boot环境，直接注册AutoConfigurationCustomizer Bean即可覆盖默认Exporter：

import io.opentelemetry.sdk.autoconfigure.AutoConfigurationCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class OtelConfig {
    @Bean
    public AutoConfigurationCustomizer otelExporterCustomizer() {
        return customizer -> customizer.addSpanExporterCustomizer((defaultExporter, configProperties) -> 
            new RetryableSpanExporter(defaultExporter)
        );
    }
}

非Spring环境可通过OpenTelemetry的SPI扩展机制注册自定义Exporter。

你遇到的SEVERE: Failed to export spans日志是OpenTelemetry内置的GrpcExporter打印的，若需要统一管控错误输出，可在日志框架配置中将io.opentelemetry.exporter.internal.grpc.GrpcExporter的日志级别调整为OFF，所有导出异常通过自定义Exporter的逻辑统一打印和处理。

• 需配合调整批量导出队列配置，避免重试导致内存溢出：otel.traces.exporter.batch.max.queue.size=2048，队列满时默认会丢弃最旧的Span，可根据业务接受度调整
• 重试总时长不要超过导出超时时间，避免请求堆积：otel.exporter.otlp.traces.timeout=10s

内容的提问来源于stack exchange，提问作者Dipak Jadhav