chore: update more occurrences of old config

confluentinc · Dec 9, 2019 · c8b43ff · c8b43ff
1 parent 7af7816
commit c8b43ff
Show file tree

Hide file tree

Showing 442 changed files with 442 additions and 442 deletions.
diff --git a/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/__version b/ksql-functional-tests/src/test/resources/expected_topology/0_6_0-pre/__version
@@ -1 +1 @@
-0_5_99
+0_5_99
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",

diff --git a/...nal-tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_long b/...nal-tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_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/...sts/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_long_table b/...sts/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_long_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_string b/...l-tests/src/test/resources/expected_topology/0_6_0-pre/collect-list_-_collect_list_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",