diff --git a/plugins/riot/src/main/java/com/redis/riot/MemKeyValueFilter.java b/plugins/riot/src/main/java/com/redis/riot/KeyValueFilter.java
similarity index 86%
rename from plugins/riot/src/main/java/com/redis/riot/MemKeyValueFilter.java
rename to plugins/riot/src/main/java/com/redis/riot/KeyValueFilter.java
index 9798f7108..46da48573 100644
--- a/plugins/riot/src/main/java/com/redis/riot/MemKeyValueFilter.java
+++ b/plugins/riot/src/main/java/com/redis/riot/KeyValueFilter.java
@@ -11,12 +11,12 @@
 
 import io.lettuce.core.codec.RedisCodec;
 
-public class MemKeyValueFilter<K, T extends KeyValue<K, ?>> implements ItemProcessor<T, T> {
+public class KeyValueFilter<K, T extends KeyValue<K, ?>> implements ItemProcessor<T, T> {
 
 	private final Function<K, String> keyToString;
 	private final Logger log;
 
-	public MemKeyValueFilter(RedisCodec<K, ?> codec, Logger log) {
+	public KeyValueFilter(RedisCodec<K, ?> codec, Logger log) {
 		this.keyToString = BatchUtils.toStringKeyFunction(codec);
 		this.log = log;
 	}
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 5aeccbb62..dcc4d7855 100644
--- a/plugins/riot/src/main/java/com/redis/riot/Replicate.java
+++ b/plugins/riot/src/main/java/com/redis/riot/Replicate.java
@@ -76,7 +76,7 @@ protected boolean isIgnoreStreamMessageId() {
 	}
 
 	private ItemProcessor<KeyValue<byte[], Object>, KeyValue<byte[], Object>> processor() {
-		return RiotUtils.processor(new MemKeyValueFilter<>(ByteArrayCodec.INSTANCE, log), keyValueProcessor());
+		return RiotUtils.processor(new KeyValueFilter<>(ByteArrayCodec.INSTANCE, log), keyValueProcessor());
 	}
 
 	private ItemProcessor<KeyValue<byte[], Object>, KeyValue<byte[], Object>> keyValueProcessor() {