diff --git a/instrumentation/spring/spring-boot-autoconfigure/src/main/java/io/opentelemetry/instrumentation/spring/autoconfigure/OpenTelemetryAutoConfiguration.java b/instrumentation/spring/spring-boot-autoconfigure/src/main/java/io/opentelemetry/instrumentation/spring/autoconfigure/OpenTelemetryAutoConfiguration.java index f4f9efc45a..ab39fb2adc 100644 --- a/instrumentation/spring/spring-boot-autoconfigure/src/main/java/io/opentelemetry/instrumentation/spring/autoconfigure/OpenTelemetryAutoConfiguration.java +++ b/instrumentation/spring/spring-boot-autoconfigure/src/main/java/io/opentelemetry/instrumentation/spring/autoconfigure/OpenTelemetryAutoConfiguration.java @@ -11,7 +11,7 @@ import io.opentelemetry.context.propagation.ContextPropagators; import io.opentelemetry.sdk.OpenTelemetrySdk; import io.opentelemetry.sdk.trace.SdkTracerProvider; import io.opentelemetry.sdk.trace.SdkTracerProviderBuilder; -import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor; +import io.opentelemetry.sdk.trace.export.BatchSpanProcessor; import io.opentelemetry.sdk.trace.export.SpanExporter; import io.opentelemetry.sdk.trace.samplers.Sampler; import java.util.Collections; @@ -45,8 +45,7 @@ public class OpenTelemetryAutoConfiguration { SdkTracerProviderBuilder tracerProviderBuilder = SdkTracerProvider.builder(); spanExportersProvider.getIfAvailable(Collections::emptyList).stream() - // todo SimpleSpanProcessor...is that really what we want here? - .map(SimpleSpanProcessor::create) + .map(spanExporter -> BatchSpanProcessor.builder(spanExporter).build()) .forEach(tracerProviderBuilder::addSpanProcessor); return tracerProviderBuilder