Skip to content

Commit 13acd8b

Browse files
committed
remove a stop-gap config option
this is no longer needed
1 parent 4cb82b6 commit 13acd8b

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

integration-tests/debezium/src/test/java/kafka/DebeziumIT.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,8 +63,7 @@ public class DebeziumIT {
6363
.dependsOn(kafkaContainer)
6464
.withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("debezium")))
6565
.withEnv("CONNECT_KEY_CONVERTER_SCHEMAS_ENABLE", "true")
66-
.withEnv("CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE", "true")
67-
.withEnv("OFFSET_FLUSH_INTERVAL_MS", "1000");
66+
.withEnv("CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE", "true");
6867

6968
@Container
7069
private final GenericContainer<?> questDBContainer = new GenericContainer<>("questdb/questdb:7.4.0")

integration-tests/exactlyonce/src/test/java/io/questdb/kafka/ExactlyOnceIT.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,6 @@ private static GenericContainer<?> newConnectContainer(int id) {
171171
return new GenericContainer<>(CONNECT_CONTAINER_IMAGE)
172172
.withEnv("CONNECT_BOOTSTRAP_SERVERS", "kafka0:9092")
173173
.withEnv("CONNECT_GROUP_ID", "test")
174-
.withEnv("CONNECT_OFFSET_FLUSH_INTERVAL_MS", "5000")
175174
.withEnv("CONNECT_OFFSET_STORAGE_TOPIC", "connect-storage-topic")
176175
.withEnv("CONNECT_CONFIG_STORAGE_TOPIC", "connect-config-topic")
177176
.withEnv("CONNECT_STATUS_STORAGE_TOPIC", "connect-status-topic")

0 commit comments

Comments
 (0)