spring-boot/me.ahoo.wow.spring.boot/ObservabilityAutoConfiguration/Companion/wowTracingTopicProducers

wowTracingTopicProducers

@Bean

fun wowTracingTopicProducers(openTelemetry: ObjectProvider<OpenTelemetry>, beans: ObjectProvider<ListableBeanFactory>): BeanPostProcessor

Wraps every TopicProducer bean in a TracingTopicProducer: a span for each Kafka produce. A bean that is also another port of the transport (an in-memory one is a PartitionedSource and a TopicAdmin too) is left as it is: the wrapper would hide those.