无法用spring-cloud-sleuth跟踪spring-cloud-stream侦听器

Question

我有两个非常简单的spring-cloud-stream应用程序。消息生产者Service3通过Binder-Kafka向消费者Service4发送消息。

我用春云侦探来追踪它们之间的跨度。但是只有Service3中的跨在zipkin服务器中可用。Service4没有显示span。

dependencies {
compile('org.springframework.boot:spring-boot-starter-web')
compile('org.springframework.boot:spring-boot-starter-thymeleaf')

compile('org.springframework.cloud:spring-cloud-starter-sleuth')

// Marshal spans over a Spring cloud stream binder
compile('org.springframework.cloud:spring-cloud-sleuth-stream')
compile('org.springframework.cloud:spring-cloud-stream-binder-kafka')

testCompile group: 'junit', name: 'junit', version: '4.11'
} 


@SpringBootApplication
public class Service3  {
    public static void main(String[] args) {
        SpringApplication.run(Service3.class, args);
    }
}


@Controller
@EnableBinding(Source.class)
public class WebController {

    @Autowired
    private Source source;


    @GetMapping("/srv4")
    private String getSrv4Info(){
        String msg = "Hello Service 4";
        this.source.output().send(MessageBuilder.withPayload(msg).build());

        return "srv4";
    }
}

dependencies {
    compile('org.springframework.boot:spring-boot-starter-web')

    compile('org.springframework.cloud:spring-cloud-starter-sleuth')

    // Marshal spans over a Spring cloud stream binder
    compile('org.springframework.cloud:spring-cloud-sleuth-stream')
    compile('org.springframework.cloud:spring-cloud-sleuth-zipkin-stream')
    compile('org.springframework.cloud:spring-cloud-stream-binder-kafka')

    runtime('io.zipkin.java:zipkin-autoconfigure-ui')

    testCompile group: 'junit', name: 'junit', version: '4.11'
}

@SpringBootApplication
@EnableZipkinStreamServer
public class Service4 {
    public static void main(String[] args) {
        SpringApplication.run(Service4.class, args);
    }
}

@EnableBinding(Sink.class)
public class MsgReceiver {
    @StreamListener(Sink.INPUT)
    private void listen(Message<String> msg){
        System.out.println(msg.getPayload());
    }
}

Answer 1

这是猜测。

Kafka没有消息头（存储跨的地方）的概念。

因此，SCSt必须在有效负载中嵌入消息头。

不幸的是，模式目前不受支持，您必须单独列出头部。我们正在考虑添加对模式和/或默认传输所有头的支持。