From 4e013753e5908856644cfca673510634e058015f Mon Sep 17 00:00:00 2001 From: Alan Sheinberg Date: Fri, 17 Dec 2021 11:14:09 -0800 Subject: [PATCH] fix: Allow disabling Scalable Push Query ALOS to be set via config --- .../resources/streaming/PushQueryConfigRoutingOptions.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/streaming/PushQueryConfigRoutingOptions.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/streaming/PushQueryConfigRoutingOptions.java index 657863635f2b..f3339d74f3bd 100644 --- a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/streaming/PushQueryConfigRoutingOptions.java +++ b/ksqldb-rest-app/src/main/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); } }