diff --git a/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java b/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java
index d127d59cc..7d2c17159 100644
--- a/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java
+++ b/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java
@@ -364,7 +364,7 @@ class DefaultStreamReceiver<K, V extends Record<K, ?>> implements StreamReceiver
 						if (logger.isDebugEnabled()) {
 							logger.debug(String.format("[stream: %s] onStreamMessage(%s): Buffering overflow", key, message));
 						}
-						overflow.add(message);
+						overflow.offer(message);
 					}
 				}