Невозможно получить идентификатор трассировки в Spring Cloud Gateway GlobalFilter (Brave + Zipkin) ⇐ JAVA

[Anonymous]

У меня есть почтовый фильтр, который пытается добавить идентификатор трассировки в ответ в виде заголовка. Я выполнил приведенные здесь предложения, но TraceContext по-прежнему имеет значение null.

Код: Выделить всё

@Slf4j
@Configuration
public class PostFilters {

public static final String CORRELATION_ID = "X-CORRELATION-ID";

@Bean
public GlobalFilter correlationIdPostFilter() {
return(exchange, chain) -> chain.filter(exchange)
.then(Mono.just(exchange))
.map(serverWebExchange ->  {
TraceContext traceContext = WebFluxSleuthOperators.currentTraceContext(serverWebExchange);
log.info("Trace Context: {}", traceContext;
if (traceContext != null) {
serverWebExchange.getResponse().getHeaders().set(CORRELATION_ID, traceContext.traceId());
}
return serverWebExchange;
})
.then();
}
}

Зависимости

Код: Выделить всё

        
org.springframework.boot
spring-boot-starter-actuator


io.micrometer
micrometer-tracing-bridge-brave


io.zipkin.reporter2
zipkin-reporter-brave


io.zipkin.reporter2
zipkin-sender-okhttp3


org.springframework.cloud
spring-cloud-sleuth-instrumentation

Основное

Код: Выделить всё

@SpringBootApplication
public class ApiGatewayApplication {

public static void main(String[] args) {
Hooks.enableAutomaticContextPropagation();
new SpringApplicationBuilder(ApiGatewayApplication.class)
.web(WebApplicationType.REACTIVE)
.run(args);
}
}

Я знаю, что контекст распространяется, поскольку вижу идентификаторы трассировки между службами в журналах и в Zipkin.

Подробнее здесь: https://stackoverflow.com/questions/793 ... ave-zipkin