diff --git a/spring-cloud-sleuth-dependencies/pom.xml b/spring-cloud-sleuth-dependencies/pom.xml
index 94bec773a..272b6af67 100644
--- a/spring-cloud-sleuth-dependencies/pom.xml
+++ b/spring-cloud-sleuth-dependencies/pom.xml
@@ -16,7 +16,7 @@
1.1.0.BUILD-SNAPSHOT
1.8.4
- 0.11.0
+ 0.12.1
1.39.3
diff --git a/spring-cloud-sleuth-samples/pom.xml b/spring-cloud-sleuth-samples/pom.xml
index bcbd9eaf9..3b7b240ba 100644
--- a/spring-cloud-sleuth-samples/pom.xml
+++ b/spring-cloud-sleuth-samples/pom.xml
@@ -59,12 +59,12 @@
io.zipkin.java
zipkin
- 0.11.0
+ 0.12.1
io.zipkin.java
zipkin-server
- 0.11.0
+ 0.12.1
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 5f745cc16..841756c11 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
@@ -24,6 +24,7 @@ import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ConditionContext;
import org.springframework.context.annotation.Conditional;
import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Lazy;
import org.springframework.context.annotation.Profile;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.Environment;
@@ -39,6 +40,7 @@ import zipkin.BinaryAnnotation.Type;
import zipkin.Endpoint;
import zipkin.Sampler;
import zipkin.Span.Builder;
+import zipkin.StorageComponent;
/**
* A message listener that is turned on if Sleuth Stream is disabled.
@@ -58,9 +60,11 @@ public class ZipkinMessageListener {
static final String UNKNOWN_PROCESS_ID = "unknown";
final AsyncSpanConsumer consumer;
+ /** lazy so transient storage errors don't crash bootstrap */
+ @Lazy
@Autowired
- ZipkinMessageListener(AsyncSpanConsumer consumer) {
- this.consumer = consumer;
+ ZipkinMessageListener(StorageComponent storage, Sampler sampler) {
+ this.consumer = storage.asyncSpanConsumer(sampler);
}
@ServiceActivator(inputChannel = SleuthSink.INPUT)