从Kafka消息在spring sleuth中注入TraceId

Question

我正在研究多微服务体系结构，其切入点来自Kafka。例如，假设micro1中有三个microservice micro1、micro2和micro3请求来自kafka消息队列，它通过Rest客户端进一步与micro2和micro3通信。

micro1接收到的消息包含requestId，我需要在spring sleuth中用它代替TraceId，它应该在所有microservice中传播。

我已经通过MDC尝试过了，但在这种情况下，traceId并没有传播到其他微服务。

有没有其他方法可以在sleuth中实现自定义TraceId而不是自动生成的？

谢谢

Answer 1

我不认为这是个好主意。保留生成的跟踪标识，并创建另一个将作为行李传播的生成字段。

如果您真的需要更改ID的生成方式，那么您必须更改这个bean

https://github.com/spring-cloud/spring-cloud-sleuth/blob/v2.0.2.RELEASE/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/autoconfig/TraceAutoConfiguration.java#L113-L133

@Bean
    @ConditionalOnMissingBean
    Propagation.Factory sleuthPropagation(SleuthProperties sleuthProperties) {
        if (sleuthProperties.getBaggageKeys().isEmpty() && sleuthProperties.getPropagationKeys().isEmpty()) {
            return B3Propagation.FACTORY;
        }
        ExtraFieldPropagation.FactoryBuilder factoryBuilder = ExtraFieldPropagation
                .newFactoryBuilder(B3Propagation.FACTORY);
        if (!sleuthProperties.getBaggageKeys().isEmpty()) {
            factoryBuilder = factoryBuilder
                    // for HTTP
                    .addPrefixedFields("baggage-", sleuthProperties.getBaggageKeys())
                    // for messaging
                    .addPrefixedFields("baggage_", sleuthProperties.getBaggageKeys());
        }
        if (!sleuthProperties.getPropagationKeys().isEmpty()) {
            for (String key : sleuthProperties.getPropagationKeys()) {
                factoryBuilder = factoryBuilder.addField(key);
            }
        }
        return factoryBuilder.build();
    }