Add 'record' prefix to key.evaluator and value.evaluator parameters

Lightstreamer · Mar 6, 2024 · 5ecb7bc · 5ecb7bc
1 parent 8aa981d
commit 5ecb7bc
Show file tree

Hide file tree

Showing 17 changed files with 132 additions and 437 deletions.
diff --git a/examples/quickstart-confluent-cloud/adapters.xml b/examples/quickstart-confluent-cloud/adapters.xml
@@ -29,8 +29,8 @@
 
         <!-- Record consumption settings -->
         <param name="record.consume.from">EARLIEST</param>
-        <param name="key.evaluator.type">INTEGER</param>
-        <param name="value.evaluator.type">JSON</param>
+        <param name="record.key.evaluator.type">INTEGER</param>
+        <param name="record.value.evaluator.type">JSON</param>
 
         <!-- Fields mapping settings -->
         <param name="field.ts">#{TIMESTAMP}</param>

diff --git a/examples/quickstart-schema-registry/adapters.xml b/examples/quickstart-schema-registry/adapters.xml
@@ -29,9 +29,9 @@
 
         <!-- Record consumption settings -->
         <param name="record.consume.from">EARLIEST</param>
-        <param name="key.evaluator.type">INTEGER</param>
-        <param name="value.evaluator.type">JSON</param>
-        <param name="value.evaluator.schema.registry.enable">true</param>
+        <param name="record.key.evaluator.type">INTEGER</param>
+        <param name="record.value.evaluator.type">JSON</param>
+        <param name="record.value.evaluator.schema.registry.enable">true</param>
 
         <!-- Schema Registry settings -->
         <param name="schema.registry.url">https://schema-registry:8084</param>

diff --git a/examples/quickstart-ssl/adapters.xml b/examples/quickstart-ssl/adapters.xml
@@ -29,8 +29,8 @@
 
         <!-- Record consumption settings -->
         <param name="record.consume.from">EARLIEST</param>
-        <param name="key.evaluator.type">INTEGER</param>
-        <param name="value.evaluator.type">JSON</param>
+        <param name="record.key.evaluator.type">INTEGER</param>
+        <param name="record.value.evaluator.type">JSON</param>
 
         <!-- Fields mapping settings -->
         <param name="field.ts">#{TIMESTAMP}</param>

diff --git a/kafka-connector/src/connector/dist/adapters.bcp.xml b/kafka-connector/src/connector/dist/adapters.bcp.xml
diff --git a/kafka-connector/src/connector/dist/adapters.xml b/kafka-connector/src/connector/dist/adapters.xml
@@ -95,8 +95,8 @@
              - UUID
              Default: STRING -->
         <!--
-        <param name="key.evaluator.type">JSON</param>
-        <param name="value.evaluator.type">JSON</param>
+        <param name="record.key.evaluator.type">JSON</param>
+        <param name="record.value.evaluator.type">JSON</param>
         -->
 
         <!-- TOPIC MAPPING SECTION -->
@@ -117,8 +117,8 @@
         <!-- Map the Kafka topic "stocks" to the previous defined "stock" item template. -->
         <param name="map.stocks.to">item-template.stock</param>
 
-        <param name="key.evaluator.type">INTEGER</param>
-        <param name="value.evaluator.type">JSON</param>
+        <param name="record.key.evaluator.type">INTEGER</param>
+        <param name="record.value.evaluator.type">JSON</param>
         <param name="record.consume.from">EARLIEST</param>
 
         <!-- FIELDS MAPPING SECTION -->

diff --git a/kafka-connector/src/connector/dist/user-key.avsc b/kafka-connector/src/connector/dist/user-key.avsc
diff --git a/kafka-connector/src/connector/dist/user-value.avsc b/kafka-connector/src/connector/dist/user-value.avsc