Configurar para iniciar un nuevo span en KafkaMessageListenerContainer no en el listener (Kafka + Sleuth)

Answer

1. 

   davy.ai

   June 15, 2023 at 2:16 pm

   Sí, es posible configurar Spring Cloud Sleuth para que inicie trazas en KafkaMessageListenerContainer en lugar de MessageListenerMethodInterceptor. Esto se puede lograr configurando el bean “TracingMessageListenerDecorator” en su configuración de Spring.

   Aquí hay un ejemplo de cómo podría hacerlo:

   @Bean
   public TracingMessageListenerDecorator tracingMessageListenerDecorator(Tracer tracer) {
       SpanExtractor<kafkamessageheaders> extractor = new KafkaMessageHeaderExtractor();
       return new TracingMessageListenerDecorator(tracer, extractor, new KafkaMessagingSpanManager(tracer));
   }
   
   @Bean
   public KafkaListenerContainerFactory<><string, string="">> kafkaListenerContainerFactory(
       TracingMessageListenerDecorator tracingMessageListenerDecorator) {
   
       ConcurrentKafkaListenerContainerFactory<string, string=""> factory = new ConcurrentKafkaListenerContainerFactory<>();
       factory.setConsumerFactory(consumerFactory());
       factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL);
       factory.getContainerProperties().setErrorHandler(new SeekToCurrentErrorHandler());
       factory.setConcurrency(3);
       factory.setAfterReceivePostProcessors(tracingMessageListenerDecorator);
       return factory;
   }
   

   En la configuración anterior, hemos definido un bean “TracingMessageListenerDecorator” que usa un “KafkaMessagingSpanManager” para iniciar trazas en el “KafkaMessageListenerContainer”. Luego, pasamos este “TracingMessageListenerDecorator” como un “afterReceivePostProcessor” para “ConcurrentKafkaListenerContainerFactory”.

   Con esta configuración, cuando “KafkaMessageListenerContainer” recibe un mensaje nuevo, Sleuth iniciará una nueva traza para él. Si ocurre una excepción durante el procesamiento del mensaje, se invocará la lógica de manejo de errores en “SeekToCurrentErrorHandler”, pero la traza actual seguirá estando disponible con las IDs de traza y span intactas.</string,></string,>

Comments are closed.