diff --git a/spring-cloud-sleuth-zipkin-stream/src/main/java/org/springframework/cloud/sleuth/zipkin/stream/ZipkinMessageListener.java b/spring-cloud-sleuth-zipkin-stream/src/main/java/org/springframework/cloud/sleuth/zipkin/stream/ZipkinMessageListener.java index 7231930a4..c46053682 100644 --- a/spring-cloud-sleuth-zipkin-stream/src/main/java/org/springframework/cloud/sleuth/zipkin/stream/ZipkinMessageListener.java +++ b/spring-cloud-sleuth-zipkin-stream/src/main/java/org/springframework/cloud/sleuth/zipkin/stream/ZipkinMessageListener.java @@ -59,7 +59,7 @@ public class ZipkinMessageListener { this.collector = Collector.builder(getClass()) .storage(storage) .sampler(sampler) - .metrics(metrics).build(); + .metrics(metrics.forTransport("stream")).build(); } @ServiceActivator(inputChannel = SleuthSink.INPUT)