temp fix for TTD test

responsivedev · Dec 9, 2024 · f178983 · f178983
1 parent 1fb2782
commit f178983
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/test/java/dev/responsive/kafka/api/ResponsiveTopologyTestDriverKeyValueStoreTest.java b/...src/test/java/dev/responsive/kafka/api/ResponsiveTopologyTestDriverKeyValueStoreTest.java
@@ -257,7 +257,7 @@ public void shouldDeduplicateWithTtlProviderToExpireOldRecords(final KVSchema ty
       assertNull(transactionIdStore.get(key), "should have no txn id in state store");
 
       // send the same event in again, outside the dedupe window
-      inputTopic.pipeInput(key, value);
+      inputTopic.pipeInput(key, value, ttlMs + 1);
       assertNotNull(
           transactionIdStore.get(key), "should have a single txn id in state store, again");
     }