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 f5cdc93..ba7b32b 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
@@ -289,8 +289,7 @@ private static void startKillingRandomContainers(CyclicBarrier barrier) {
}
private static void startConnector() throws IOException, InterruptedException, URISyntaxException {
- String confString = "http::addr=questdb:9000;auto_flush_rows=10000;";
-
+ String confString = "http::addr=questdb:9000;auto_flush_rows=10000;auto_flush_interval=1200000;retry_timeout=60000;";
String payload = "{\"name\":\"my-connector\",\"config\":{" +
"\"tasks.max\":\"4\"," +
diff --git a/pom.xml b/pom.xml
index 62f8de7..aa8d808 100644
--- a/pom.xml
+++ b/pom.xml
@@ -84,7 +84,7 @@
org.questdb
questdb
- 7.4.1-SNAPSHOT
+ 7.4.0
org.junit.jupiter