fix: Allow disabling Scalable Push Query ALOS to be set via config (#…

…8542)
confluentinc · Dec 21, 2021 · 7ac36e0 · 7ac36e0
1 parent 9d6a61b
commit 7ac36e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...java/io/confluent/ksql/rest/server/resources/streaming/PushQueryConfigRoutingOptions.java b/...java/io/confluent/ksql/rest/server/resources/streaming/PushQueryConfigRoutingOptions.java
@@ -92,6 +92,6 @@ public boolean alosEnabled() {
     if (configOverrides.containsKey(KsqlConfig.KSQL_QUERY_PUSH_V2_ALOS_ENABLED)) {
       return (Boolean) configOverrides.get(KsqlConfig.KSQL_QUERY_PUSH_V2_ALOS_ENABLED);
     }
-    return KsqlConfig.KSQL_QUERY_PUSH_V2_ALOS_ENABLED_DEFAULT;
+    return ksqlConfig.getBoolean(KsqlConfig.KSQL_QUERY_PUSH_V2_ALOS_ENABLED);
   }
 }