integration test explicity set rewind offset

questdb · Oct 31, 2023 · 1097862 · 1097862
1 parent b017717
commit 1097862
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/integration-tests/exactlyonce/src/test/java/io/questdb/kafka/ExactlyOnceIT.java b/integration-tests/exactlyonce/src/test/java/io/questdb/kafka/ExactlyOnceIT.java
@@ -301,6 +301,7 @@ private static void startConnector() throws IOException, InterruptedException, U
                 "\"value.converter\":\"org.apache.kafka.connect.json.JsonConverter\"," +
                 "\"topics\":\"mytopic\"," +
                 "\"value.converter.schemas.enable\":\"false\"," +
+                "\"dedup.rewind.offset\":\"150000\"," +
                 "\"timestamp.field.name\":\"ts\"," +
                 "\"host\":\"questdb:9009\"}" +
                 "}";