diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java
index 06490aa79..7f6123beb 100644
--- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java
+++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java
@@ -943,7 +943,7 @@ public class LettuceConnection extends AbstractRedisConnection {
 	}
 
 	RedisClusterAsyncCommands<byte[], byte[]> getAsyncConnection() {
-		if (isQueueing()) {
+		if (isQueueing() || isPipelined()) {
 			return getAsyncDedicatedConnection();
 		}
 		if (asyncSharedConn != null) {