@ -198,7 +198,7 @@ public class RedisStreamConsumer {
Consumer.from(GROUP, consumerName),
StreamReadOptions.empty()
.count(20)
.block(Duration.ofSeconds(2)),
.block(Duration.ofSeconds(1)),
StreamOffset.create(stream, ReadOffset.lastConsumed())
);