This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new e05a8a675b9 Fix integration test slowdown caused by embedded Kafka
fsyncing every… (#17856)
e05a8a675b9 is described below
commit e05a8a675b912307ed146224f3e2959742ae8950
Author: Kartik Khare <[email protected]>
AuthorDate: Wed Mar 11 11:59:27 2026 +0530
Fix integration test slowdown caused by embedded Kafka fsyncing every…
(#17856)
---
.../apache/pinot/plugin/stream/kafka30/server/EmbeddedKafkaCluster.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/server/EmbeddedKafkaCluster.java
b/pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/server/EmbeddedKafkaCluster.java
index a196353c4a8..56b3fe8eef2 100644
---
a/pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/server/EmbeddedKafkaCluster.java
+++
b/pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/server/EmbeddedKafkaCluster.java
@@ -74,7 +74,7 @@ public class EmbeddedKafkaCluster implements
StreamDataServerStartable {
.setConfigProp("transaction.state.log.min.isr", "1")
.setConfigProp("transaction.state.log.num.partitions", "1")
.setConfigProp("group.initial.rebalance.delay.ms", "0")
- .setConfigProp("log.flush.interval.messages", "1")
+
.build();
_cluster.format();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
