diff --git a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java
index 47ba879fd..3eb2510cd 100644
--- a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java
+++ b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java
@@ -24,6 +24,7 @@ import org.reactivestreams.Publisher;
 import org.springframework.beans.factory.BeanFactory;
 import reactor.core.Fuseable;
 import reactor.core.Scannable;
+import reactor.core.publisher.ConnectableFlux;
 import reactor.core.publisher.Operators;
 import reactor.util.context.Context;
 
@@ -102,7 +103,7 @@ public abstract class ReactorSleuth {
 	}
 
 	private static final Predicate<Scannable> POINTCUT_FILTER =
-			s ->  !(s instanceof Fuseable.ScalarCallable) && s.isScanAvailable();
+			s ->  !(s instanceof ConnectableFlux) && !(s instanceof Fuseable.ScalarCallable) && s.isScanAvailable();
 
 	private ReactorSleuth() {
 	}