Ignore keys with TTL

core/riot-core/src/main/java/com/redis/riot/core/processor/IgnoreKeysWithTTLProcessor.java

@@ -0,0 +1,14 @@
+package com.redis.riot.core.processor;
+
+import com.redis.spring.batch.common.KeyValue;
+import org.springframework.batch.item.ItemProcessor;
+
+public class IgnoreKeysWithTTLProcessor implements ItemProcessor<KeyValue<byte[]>, KeyValue<byte[]>> {
+    @Override
+    public KeyValue<byte[]> process( KeyValue<byte[]> item) throws Exception {
+        if ( item.getTtl() > 0L ) {
+            return null;
+        }
+        return item;
+    }
+}

plugins/riot/src/main/java/com/redis/riot/cli/Replicate.java

@@ -7,6 +7,7 @@
 import java.util.concurrent.BlockingQueue;
 import java.util.logging.Logger;
 
+import com.redis.riot.core.processor.IgnoreKeysWithTTLProcessor;
 import org.springframework.batch.core.Job;
 import org.springframework.batch.core.job.builder.FlowBuilder;
 import org.springframework.batch.core.job.builder.JobFlowBuilder;
@@ -167,7 +168,8 @@ private Job liveJob(ReplicateCommandContext context) {
 
 	private boolean shouldCompare() {
 		return !replicateOptions.isNoVerify() && !writerOptions.isDryRun()
-				&& !replicateOptions.getKeyProcessor().isPresent();
+				&& !replicateOptions.getKeyProcessor().isPresent()
+				&& !replicateOptions.isIgnoreKeysWithTtl();
 	}
 
 	private SimpleStepBuilder<KeyValue<byte[]>, KeyValue<byte[]>> scanStep(ReplicateCommandContext context) {
@@ -263,6 +265,9 @@ private ItemProcessor<KeyValue<byte[]>, KeyValue<byte[]>> processor(ReplicateCom
 			Expression expression = parser.parseExpression(p);
 			processors.add(new KeyValueProcessor(expression, evaluationContext));
 		});
+		if (replicateOptions.isIgnoreKeysWithTtl()) {
+			processors.add(new IgnoreKeysWithTTLProcessor());
+		}
 		return CompositeItemStreamItemProcessor.delegates(processors.toArray(new ItemProcessor[0]));
 	}
 

plugins/riot/src/main/java/com/redis/riot/cli/common/ReplicateOptions.java

@@ -36,6 +36,9 @@ public class ReplicateOptions {
 	@Option(names = "--ttl-tolerance", description = "Max TTL difference to use for dataset verification (default: ${DEFAULT-VALUE}).", paramLabel = "<ms>")
 	private long ttlTolerance = KeyComparisonItemReader.DEFAULT_TTL_TOLERANCE.toMillis();
 
+	@Option(names = "--ignore-ttl-keys", description = "Ignore keys with TTL (default: false)", paramLabel = "<bool>")
+	private boolean ignoreKeysWithTtl = false;
+
 	@Option(names = "--show-diffs", description = "Print details of key mismatches during dataset verification. Disables progress reporting.")
 	private boolean showDiffs;
 
@@ -151,6 +154,15 @@ public void setShowDiffs(boolean showDiffs) {
 		this.showDiffs = showDiffs;
 	}
 
+
+	public boolean isIgnoreKeysWithTtl() {
+		return ignoreKeysWithTtl;
+	}
+
+	public void setIgnoreKeysWithTtl(boolean ignoreKeysWithTtl) {
+		this.ignoreKeysWithTtl = ignoreKeysWithTtl;
+	}
+
 	public PoolOptions targetPoolOptions() {
 		return PoolOptions.builder().maxTotal(targetPoolMaxTotal).build();
 	}