fix the Predicate search #69

michelin · Nov 23, 2023 · 41b013a · 41b013a
1 parent 1570a47
commit 41b013a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...re/src/main/java/com/michelin/kstreamplify/deduplication/DedupWithPredicateProcessor.java b/...re/src/main/java/com/michelin/kstreamplify/deduplication/DedupWithPredicateProcessor.java
@@ -81,7 +81,7 @@ public void process(Record<K, V> message) {
                     currentInstant.plus(retentionWindowDuration))) {
                 while (resultIterator != null && resultIterator.hasNext()) {
                     var currentKeyValue = resultIterator.next();
-                    if (message.value().equals(currentKeyValue.value)) {
+                    if (identifier.equals(deduplicationKeyExtractor.apply(currentKeyValue.value))) {
                         return;
                     }
                 }