From 25896219beb0efc8a057a9444b3c42ef2de16670 Mon Sep 17 00:00:00 2001
From: jruaux <jruaux@gmail.com>
Date: Mon, 30 Sep 2024 14:35:11 -0700
Subject: [PATCH] fix: Removed duplicate max item count

---
 plugins/riot/src/main/java/com/redis/riot/Replicate.java | 2 --
 1 file changed, 2 deletions(-)

diff --git a/plugins/riot/src/main/java/com/redis/riot/Replicate.java b/plugins/riot/src/main/java/com/redis/riot/Replicate.java
index 303b9bd8a..bc6b20109 100644
--- a/plugins/riot/src/main/java/com/redis/riot/Replicate.java
+++ b/plugins/riot/src/main/java/com/redis/riot/Replicate.java
@@ -13,7 +13,6 @@
 import com.redis.spring.batch.item.redis.reader.KeyComparisonItemReader;
 import com.redis.spring.batch.item.redis.reader.KeyEventStatus;
 import com.redis.spring.batch.item.redis.reader.KeyNotificationItemReader;
-import com.redis.spring.batch.item.redis.reader.RedisScanSizeEstimator;
 
 import io.lettuce.core.codec.ByteArrayCodec;
 import picocli.CommandLine.ArgGroup;
@@ -81,7 +80,6 @@ private Step<KeyValue<byte[], Object>, KeyValue<byte[], Object>> step() {
 		if (reader.getMode() != ReaderMode.SCAN) {
 			step.statusMessageSupplier(() -> liveExtraMessage(reader));
 		}
-		step.maxItemCountSupplier(RedisScanSizeEstimator.from(reader));
 		if (logKeys) {
 			log.info("Adding key logger");
 			ReplicateWriteLogger<byte[], Object> writeLogger = new ReplicateWriteLogger<>(log, reader.getCodec());