chore: update KSQL_PULL_QUERIES_ENABLE_CONFIG name (MINOR) (#4059)

confluentinc · Dec 10, 2019 · 9a2bdec · 9a2bdec
1 parent 4c6caa6
commit 9a2bdec
Show file tree

Hide file tree

Showing 457 changed files with 459 additions and 459 deletions.
diff --git a/ksql-common/src/main/java/io/confluent/ksql/config/ImmutableProperties.java b/ksql-common/src/main/java/io/confluent/ksql/config/ImmutableProperties.java
@@ -29,7 +29,7 @@ public final class ImmutableProperties {
       .add(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG)
       .add(KsqlConfig.KSQL_EXT_DIR)
       .add(KsqlConfig.KSQL_ACTIVE_PERSISTENT_QUERY_LIMIT_CONFIG)
-      .add(KsqlConfig.KSQL_QUERY_PULL_ENABLE_CONFIG)
+      .add(KsqlConfig.KSQL_PULL_QUERIES_ENABLE_CONFIG)
       .add(KsqlConfig.KSQL_PULL_QUERIES_SKIP_ACCESS_VALIDATOR_CONFIG)
       .addAll(KsqlConfig.SSL_CONFIG_NAMES)
       .build();

diff --git a/ksql-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java b/ksql-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java
@@ -167,7 +167,7 @@ public class KsqlConfig extends AbstractConfig {
       + " which are secured with ACLs. Please enable only after careful consideration."
       + " If \"false\", KSQL pull queries will fail against a secure Kafka cluster";
 
-  public static final String KSQL_QUERY_PULL_ENABLE_CONFIG = "ksql.query.pull.enable";
+  public static final String KSQL_PULL_QUERIES_ENABLE_CONFIG = "ksql.pull.queries.enable";
   public static final String KSQL_QUERY_PULL_ENABLE_DOC =
       "Config to enable or disable transient pull queries on a specific KSQL server.";
   public static final boolean KSQL_QUERY_PULL_ENABLE_DEFAULT = true;
@@ -464,7 +464,7 @@ private static ConfigDef buildConfigDef(final ConfigGeneration generation) {
             Importance.LOW,
             METRIC_REPORTER_CLASSES_DOC
         ).define(
-            KSQL_QUERY_PULL_ENABLE_CONFIG,
+            KSQL_PULL_QUERIES_ENABLE_CONFIG,
             Type.BOOLEAN,
             KSQL_QUERY_PULL_ENABLE_DEFAULT,
             Importance.LOW,

diff --git a/.../0_6_0-pre/arraycontains_-_filter_rows_where_the_ARRAY_column_contains_a_specified_STRING b/.../0_6_0-pre/arraycontains_-_filter_rows_where_the_ARRAY_column_contains_a_specified_STRING
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...re/arraycontains_-_filter_rows_where_the_STRUCT-_ARRAY_column_contains_a_specified_STRING b/...re/arraycontains_-_filter_rows_where_the_STRUCT-_ARRAY_column_contains_a_specified_STRING
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...t/resources/expected_topology/0_6_0-pre/arrayindex_-_select_the_first_element_of_an_Array b/...t/resources/expected_topology/0_6_0-pre/arrayindex_-_select_the_first_element_of_an_Array
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...sources/expected_topology/0_6_0-pre/arrayindex_-_select_the_last_element_of_an_Array_(-1) b/...sources/expected_topology/0_6_0-pre/arrayindex_-_select_the_last_element_of_an_Array_(-1)
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...c/test/resources/expected_topology/0_6_0-pre/asarray_-_construct_a_list_from_two_elements b/...c/test/resources/expected_topology/0_6_0-pre/asarray_-_construct_a_list_from_two_elements
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...ts/src/test/resources/expected_topology/0_6_0-pre/asmap_-_create_map_from_key_value_lists b/...ts/src/test/resources/expected_topology/0_6_0-pre/asmap_-_create_map_from_key_value_lists
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...tional-tests/src/test/resources/expected_topology/0_6_0-pre/average-udaf_-_average_double b/...tional-tests/src/test/resources/expected_topology/0_6_0-pre/average-udaf_-_average_double
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...unctional-tests/src/test/resources/expected_topology/0_6_0-pre/average-udaf_-_average_int b/...unctional-tests/src/test/resources/expected_topology/0_6_0-pre/average-udaf_-_average_int
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...nctional-tests/src/test/resources/expected_topology/0_6_0-pre/average-udaf_-_average_long b/...nctional-tests/src/test/resources/expected_topology/0_6_0-pre/average-udaf_-_average_long
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...ests/src/test/resources/expected_topology/0_6_0-pre/average_-_calculate_average_in_select b/...ests/src/test/resources/expected_topology/0_6_0-pre/average_-_calculate_average_in_select
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/.../test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_array_dereference b/.../test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_array_dereference
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...l-tests/src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_bigint b/...l-tests/src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_bigint
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_floating_point b/...src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_floating_point
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...tests/src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_integers b/...tests/src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_integers
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...esources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_integers_and_expressions b/...esources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_integers_and_expressions
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...rces/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_integers_and_variable_values b/...rces/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_integers_and_variable_values
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/.../src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_string_values b/.../src/test/resources/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_string_values
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...rces/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_string_values_with_substring b/...rces/expected_topology/0_6_0-pre/between_-_test_BETWEEN_with_string_values_with_substring
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...s/src/test/resources/expected_topology/0_6_0-pre/between_-_test_NOT_BETWEEN_with_integers b/...s/src/test/resources/expected_topology/0_6_0-pre/between_-_test_NOT_BETWEEN_with_integers
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...src/test/resources/expected_topology/0_6_0-pre/case-expression_-_searched_case_expression b/...src/test/resources/expected_topology/0_6_0-pre/case-expression_-_searched_case_expression
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...expression_-_searched_case_expression_with_structs,_multiple_expression_and_the_same_type b/...expression_-_searched_case_expression_with_structs,_multiple_expression_and_the_same_type
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...ected_topology/0_6_0-pre/case-expression_-_searched_case_returning_null_in_default_branch b/...ected_topology/0_6_0-pre/case-expression_-_searched_case_returning_null_in_default_branch
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...xpected_topology/0_6_0-pre/case-expression_-_searched_case_returning_null_in_first_branch b/...xpected_topology/0_6_0-pre/case-expression_-_searched_case_returning_null_in_first_branch
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...xpected_topology/0_6_0-pre/case-expression_-_searched_case_returning_null_in_later_branch b/...xpected_topology/0_6_0-pre/case-expression_-_searched_case_returning_null_in_later_branch
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...d_topology/0_6_0-pre/case-expression_-_searched_case_with_arithmetic_expression_in_result b/...d_topology/0_6_0-pre/case-expression_-_searched_case_with_arithmetic_expression_in_result
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...t/resources/expected_topology/0_6_0-pre/case-expression_-_searched_case_with_null_in_when b/...t/resources/expected_topology/0_6_0-pre/case-expression_-_searched_case_with_null_in_when
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_decimal_to_decimal b/...functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_decimal_to_decimal
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_decimal_to_other b/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_decimal_to_other
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_double_to_decimal b/...-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_double_to_decimal
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_integer_to_decimal b/...functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_integer_to_decimal
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_no_op b/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_no_op
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_of_nulls b/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_of_nulls
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_string_to_decimal b/...-functional-tests/src/test/resources/expected_topology/0_6_0-pre/cast_-_string_to_decimal
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_bool_map b/...tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_bool_map
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_bool_map_table b/...src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_bool_map_table
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...l-tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_double b/...l-tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_double
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...s/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_double_table b/...s/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_double_table
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...onal-tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_int b/...onal-tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_int
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",

diff --git a/...ests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_int_table b/...ests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_int_table
@@ -13,7 +13,7 @@
   "ksql.internal.topic.min.insync.replicas" : "1",
   "ksql.internal.topic.replicas" : "1",
   "ksql.insert.into.values.enabled" : "true",
-  "ksql.query.pull.enable" : "true",
+  "ksql.pull.queries.enable" : "true",
   "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
   "ksql.access.validator.enable" : "auto",
   "ksql.streams.bootstrap.servers" : "localhost:0",