diff --git a/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java b/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java
index e51f58ad0..393efea01 100644
--- a/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java
+++ b/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java
@@ -93,7 +93,7 @@ protected String zookeeperConnection() {
      */
     protected void populateDefaultConfiguration(Properties props) {
         config.setProperty(KafkaConfig.NumPartitionsProp(), String.valueOf(1));
-        config.setProperty(KafkaConfig.LogFlushIntervalMessagesProp(), String.valueOf(1));
+        config.setProperty(KafkaConfig.LogFlushIntervalMessagesProp(), String.valueOf(Long.MAX_VALUE));
     }
 
     /**