Disable Kafka log segment rotation for flink tests

pinterest · Oct 24, 2024 · 1849158 · 1849158
1 parent ccbf61d
commit 1849158
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...com/pinterest/flink/streaming/connectors/psc/PscTestEnvironmentWithKafkaAsPubSubImpl.java b/...com/pinterest/flink/streaming/connectors/psc/PscTestEnvironmentWithKafkaAsPubSubImpl.java
@@ -498,6 +498,7 @@ protected KafkaServer getKafkaServer(int brokerId, File tmpFolder) throws Except
         kafkaProperties.put("message.max.bytes", String.valueOf(50 * 1024 * 1024));
         kafkaProperties.put("replica.fetch.max.bytes", String.valueOf(50 * 1024 * 1024));
         kafkaProperties.put("transaction.max.timeout.ms", Integer.toString(1000 * 60 * 60 * 2)); // 2hours
+        kafkaProperties.put("log.retention.check.interval.ms", Long.MAX_VALUE); // disable Kafka log segment rotation
 
         // for CI stability, increase zookeeper session timeout
         kafkaProperties.put("zookeeper.session.timeout.ms", zkTimeout);