You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2026/02/22 06:58:41 UTC

(pinot) 01/01: Start kafka without creating topic for CustomDataQueryClusterIntegrationTest

This is an automated email from the ASF dual-hosted git repository.

xiangfu pushed a commit to branch start-kafka-without-creating-topic
in repository https://gitbox.apache.org/repos/asf/pinot.git

commit f818812d7b1ba6322238db423f71acabadd247fa
Author: Xiang Fu <xi...@startree.ai>
AuthorDate: Sat Feb 21 22:57:03 2026 -0800

    Start kafka without creating topic for CustomDataQueryClusterIntegrationTest
---
 .../integration/tests/custom/CustomDataQueryClusterIntegrationTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/CustomDataQueryClusterIntegrationTest.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/CustomDataQueryClusterIntegrationTest.java
index cac229e8bec..5714057a7a8 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/CustomDataQueryClusterIntegrationTest.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/CustomDataQueryClusterIntegrationTest.java
@@ -74,7 +74,7 @@ public abstract class CustomDataQueryClusterIntegrationTest extends BaseClusterI
     // Start the Pinot cluster
     startZk();
     LOGGER.warn("Start Kafka in the integration test suite");
-    startKafka();
+    startKafkaWithoutTopic();
     startController();
     startBroker();
     startServer();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org