[server][controller] Disable topic existence check in consumer subscr…

…ibe API (#768)
linkedin · Nov 21, 2023 · 96503fd · 96503fd
1 parent 8ea3a55
commit 96503fd
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/internal/venice-common/src/main/java/com/linkedin/venice/pubsub/PubSubConstants.java b/internal/venice-common/src/main/java/com/linkedin/venice/pubsub/PubSubConstants.java
@@ -32,5 +32,5 @@ public class PubSubConstants {
   public static final int PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS_DEFAULT_VALUE = 1000;
 
   public static final String PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE = "pubsub.consumer.check.topic.existence";
-  public static final boolean PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE = true;
+  public static final boolean PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE = false;
 }
diff --git a/...tegrationTest/java/com/linkedin/venice/pubsub/api/consumer/PubSubConsumerAdapterTest.java b/...tegrationTest/java/com/linkedin/venice/pubsub/api/consumer/PubSubConsumerAdapterTest.java
@@ -1,5 +1,6 @@
 package com.linkedin.venice.pubsub.api.consumer;
 
+import static com.linkedin.venice.pubsub.PubSubConstants.PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE;
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertFalse;
 import static org.testng.Assert.assertNotNull;
@@ -112,6 +113,7 @@ public void setUpMethod() {
         String.valueOf(PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS));
     properties.putAll(pubSubBrokerWrapper.getAdditionalConfig());
     properties.putAll(pubSubBrokerWrapper.getMergeableConfigs());
+    properties.put(PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE, "true");
     VeniceProperties veniceProperties = new VeniceProperties(properties);
 
     pubSubConsumerAdapter = pubSubClientsFactory.getConsumerAdapterFactory()