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 708344cc2..408538e15 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
@@ -935,7 +935,7 @@ public class LettuceConnection extends AbstractRedisConnection {
 
 	RedisClusterAsyncCommands<byte[], byte[]> getAsyncConnection() {
 
-		if (isQueueing()) {
+		if (isQueueing() || isPipelined()) {
 			return getAsyncDedicatedConnection();
 		}