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
index aa07fd1..08c8d45 100644
--- 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\"}" +
                 "}";