diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java index 35e59b9ea..36f656419 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java @@ -366,7 +366,7 @@ class LettuceStreamCommands implements RedisStreamCommands { io.lettuce.core.Range lettuceRange = RangeConverter.toRange(range, Function.identity()); io.lettuce.core.Limit lettuceLimit = LettuceConverters.toLimit(limit); - return connection.invoke(getAsyncDedicatedConnection()) + return connection.invoke() .fromMany(RedisStreamAsyncCommands::xrevrange, key, lettuceRange, lettuceLimit) .toList(StreamConverters.byteRecordConverter()); }