Tag: SPRING-CLOUD-SLEUTH
¿Cómo podemos hacer que un BaggageField de Spring Cloud Sleuth funcione en Spring IntegrationFlow? Necesito ayuda para agregarlo en el IntegrationFlow DSL. Lo agregué en un transform(), sin embargo, no se refleja. spring.sleuth.baggage.local-fields: customField spring.sleuth.baggage.correlation-fields: customField @Bean public BaggageField customField() { return BaggageField.create(“customField”); } @Bean public ScopeDecorator mdcScopeDecorator() { return . . . Read more
Tengo una aplicación de Spring Cloud Gateway muy simple (nada personalizado, descargado directamente desde start.spring.io, solo selecciona gateway y sleuth). Para habilitar los registros de acceso, debo establecer la propiedad del sistema reactor.netty.http.server.accessLogEnabled: @SpringBootApplication class Application fun main(args: Array<string>) { System.setProperty(ReactorNetty.ACCESS_LOG_ENABLED, “true”) runApplication<application>(*args) } Y todo funciona perfectamente: … 2021-12-27 . . . Read more
Estoy escribiendo una librería para proyectos que utilizan diferentes versiones de Spring. La librería en sí está basada en Spring también (más precisamente, Spring Cloud Sleuth). Por ahora, uso diferentes versiones para diferentes proyectos (versión 1 para proyectos que utilizan Spring Boot 2.0.x, versión 2 para proyectos que utilizan Spring . . . Read more
Tengo una aplicación de Spring Boot que depende de spring-cloud-starter-sleuth-3.0.3 y spring-cloud-sleuth-zipkin-3.0.3. Tengo un requisito de pasar el trace-id al encabezado de la solicitud al llamar a la API desde webclient. Demo webClient @Slf4j @Component @RequiredArgsConstructor public class DemoApiClient { private final WebClient demoWebClient; private final DemoProperties demoProperties; private final . . . Read more
Estoy actualizando una aplicación Spring Boot a Boot 2.6.1, Cloud 2021.0.0 y Cloud Stream 3.2.1. Esta aplicación tiene una serie de KStreams como: @Bean fun processEvent(): Function<><id, eventreceived=””>, KStream<id, updatedinfo?=””>> { … } Ahora la aplicación se bloquea al iniciar: Caused by: org.springframework.kafka.KafkaException: No se pudo iniciar el stream; la . . . Read more