From 2151d0d3b3a239b1d3b4159efe0ece3c5f54fd42 Mon Sep 17 00:00:00 2001
From: Gianluca <gianluca.finocchiaro@lightstreamer.com>
Date: Mon, 11 Mar 2024 17:39:28 +0100
Subject: [PATCH] Checkpoint

---
 examples/docker/Dockerfile                    |  2 +-
 examples/docker/build.sh                      |  2 +-
 kafka-connector/build.gradle                  |  2 +-
 .../src/connector/dist/adapters.xml           | 21 +++++++++++++++----
 4 files changed, 20 insertions(+), 7 deletions(-)

diff --git a/examples/docker/Dockerfile b/examples/docker/Dockerfile
index 080b1925..686fb2f4 100644
--- a/examples/docker/Dockerfile
+++ b/examples/docker/Dockerfile
@@ -4,7 +4,7 @@ FROM lightstreamer
 # The Kafka Connector project version
 ARG VERSION
 
-ENV KAFKA_CONNECTOR_NAME=lightstreamer-kafka-connector-deploy-${VERSION}
+ENV KAFKA_CONNECTOR_NAME=lightstreamer-kafka-connector-${VERSION}
 ENV KAFKA_CONNECTOR_ZIP=${KAFKA_CONNECTOR_NAME}.zip
 ENV DEPLOY_DIR=/lightstreamer/adapters/${KAFKA_CONNECTOR_NAME}
 
diff --git a/examples/docker/build.sh b/examples/docker/build.sh
index 257d7a18..37cc0340 100755
--- a/examples/docker/build.sh
+++ b/examples/docker/build.sh
@@ -8,7 +8,7 @@ echo "Making the deployment package"
 $_gradle distribuite
 
 rm -fr  ${TMP_DIR}; mkdir ${TMP_DIR}
-cp ${projectDir}/deploy/lightstreamer-kafka-connector-deploy-${version}.zip ${TMP_DIR}
+cp ${projectDir}/deploy/lightstreamer-kafka-connector-${version}.zip ${TMP_DIR}
 
 echo "Build the Lightstramer Kafka Connector Docker image"
 docker build -t lightstreamer-kafka-connector-${version} $SCRIPT_DIR --build-arg VERSION=${version}
diff --git a/kafka-connector/build.gradle b/kafka-connector/build.gradle
index 5e1c28a7..d19c7a32 100644
--- a/kafka-connector/build.gradle
+++ b/kafka-connector/build.gradle
@@ -39,7 +39,7 @@ javadoc {
 
 distributions {
 	connector {
-		distributionBaseName = rootProject.name + '-deploy'
+		distributionBaseName = rootProject.name
 
 		contents {
 			from(jar) {
diff --git a/kafka-connector/src/connector/dist/adapters.xml b/kafka-connector/src/connector/dist/adapters.xml
index 2ac52398..036882a0 100644
--- a/kafka-connector/src/connector/dist/adapters.xml
+++ b/kafka-connector/src/connector/dist/adapters.xml
@@ -281,15 +281,15 @@
         <param name="record.key.evaluator.type">INTEGER</param>
         <param name="record.value.evaluator.type">JSON</param>
 
-        <!-- Mandatory if evaluator type is AVRO. The path of the local schema file relative to
-             the deployment folder (LS_HOME/adapters/lightstreamer-kafka-connector-<version>) for message validation 
-             respectively of the Kafka key and the Kafa value. -->
+        <!-- Mandatory if evaluator type is AVRO and the Confluent Schema Registry is disabled. The path of the local schema 
+             file relative to the deployment folder (LS_HOME/adapters/lightstreamer-kafka-connector-<version>) for 
+             message validation respectively of the Kafka key and the Kafa value. -->
         <!--
         <param name="record.key.evaluator.schema.path">schema/record_key.avsc</param>
         <param name="record.value.evaluator.schema.path">schemas/record_value.avsc</param>
         -->
 
-        <!-- Optional. Enable the use of the Confluent Schema Registry for validation respectively of the Kafka key and 
+        <!-- Mandatory if evaluator type is AVRO and no local schema paths are specified. Enable the use of the Confluent Schema Registry for validation respectively of the Kafka key and 
              the Kafa value. Can be one of the following:
              - true
              - false
@@ -369,6 +369,19 @@
         <param name="field.ref_price">#{VALUE.ref_price}</param>
         <param name="field.open_price">#{VALUE.open_price}</param>
         <param name="field.item_status">#{VALUE.item_status}</param>
+
+        <!-- ##### SCHEMA REGISTRY SETTINGS ##### -->
+
+        <!-- Mandatory if the Confluent Schema Registry is enabled. The URL of the Confluent Schema Registry.
+             An encrypted connection is enabled by specifying the "https" protocol 
+        -->
+        <param name="schema.registry.url">https://schema-registry:8084</param>
+        <param name="schema.registry.encryption.truststore.path">secrets/kafka-connector.truststore.jks</param>
+        <param name="schema.registry.encryption.truststore.password">kafka-connector-truststore-password</param>
+        <param name="schema.registry.encryption.keystore.enable">true</param>
+        <param name="schema.registry.encryption.keystore.path">secrets/kafka-connector.keystore.jks</param>
+        <param name="schema.registry.encryption.keystore.password">kafka-connector-password</param>
+        <param name="schema.registry.encryption.keystore.key.password">kafka-connector-private-key-password</param>
     </data_provider>
 
 </adapters_conf>