From 0894b5cd19ba304bf63cc4b642da3ec0bb611533 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:33:59 +0530
Subject: [PATCH 01/15] Update Gradle files to build examples

---
 build.gradle          |  1 +
 examples/build.gradle | 76 +++++++++++++++++++++++++++++++++++++++++++
 examples/build.sh     | 55 +++++++++++++++++++++++++++++++
 settings.gradle       |  2 ++
 4 files changed, 134 insertions(+)
 create mode 100644 examples/build.gradle
 create mode 100755 examples/build.sh

diff --git a/build.gradle b/build.gradle
index 7301168..40c1e4e 100644
--- a/build.gradle
+++ b/build.gradle
@@ -82,6 +82,7 @@ subprojects {
 task build {
     dependsOn(":confluent.cavroserdes-native:build")
     dependsOn(":confluent.cavroserdes-ballerina:build")
+    dependsOn(":confluent.cavroserdes-examples:build")
 }
 
 def moduleVersion = project.version.replace("-SNAPSHOT", "")
diff --git a/examples/build.gradle b/examples/build.gradle
new file mode 100644
index 0000000..eba5913
--- /dev/null
+++ b/examples/build.gradle
@@ -0,0 +1,76 @@
+/*
+ * Copyright (c) 2024, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+ *
+ * WSO2 Inc. licenses this file to you under the Apache License,
+ * Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import org.apache.tools.ant.taskdefs.condition.Os
+
+def graalvmFlag = ""
+
+task testExamples {
+    if (project.hasProperty("balGraalVMTest")) {
+        graalvmFlag = "--graalvm"
+    }
+    doLast {
+        try {
+            exec {
+                workingDir project.projectDir
+                println("Working dir: ${workingDir}")
+                if (Os.isFamily(Os.FAMILY_WINDOWS)) {
+                    commandLine 'sh', "/c", "chmod +x ./build.sh && ./build.sh run && exit %%ERRORLEVEL%%"
+                } else {
+                    commandLine 'sh', "-c", "chmod +x ./build.sh && ./build.sh run"
+                }
+            }
+        } catch (Exception e) {
+            println("Example Build failed: " + e.message)
+            throw e
+        }
+    }
+}
+
+task buildExamples {
+    gradle.taskGraph.whenReady { graph ->
+        if (graph.hasTask(":confluent.cregistry-examples:test")) {
+            buildExamples.enabled = false
+        } else {
+            testExamples.enabled = false
+        }
+    }
+    doLast {
+        try {
+            exec {
+                workingDir project.projectDir
+                println("Working dir: ${workingDir}")
+                if (Os.isFamily(Os.FAMILY_WINDOWS)) {
+                    commandLine 'sh', "/c", "chmod +x ./build.sh && ./build.sh build && exit %%ERRORLEVEL%%"
+                } else {
+                    commandLine 'sh', "-c", "chmod +x ./build.sh && ./build.sh build"
+                }
+            }
+        } catch (Exception e) {
+            println("Example Build failed: " + e.message)
+            throw e
+        }
+    }
+}
+
+task build {
+    dependsOn buildExamples
+}
+
+buildExamples.dependsOn ":confluent.cavroserdes-ballerina:build"
+testExamples.dependsOn ":confluent.cavroserdes-ballerina:build"
diff --git a/examples/build.sh b/examples/build.sh
new file mode 100755
index 0000000..e2659d3
--- /dev/null
+++ b/examples/build.sh
@@ -0,0 +1,55 @@
+#!/bin/bash
+
+BAL_EXAMPLES_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
+BAL_CENTRAL_DIR="$HOME/.ballerina/repositories/central.ballerina.io/"
+BAL_HOME_DIR="$BAL_EXAMPLES_DIR/../ballerina"
+
+set -e
+
+case "$1" in
+build)
+  BAL_CMD="build"
+  ;;
+run)
+  BAL_CMD="run"
+  ;;
+*)
+  echo "Invalid command provided: '$1'. Please provide 'build' or 'run' as the command."
+  exit 1
+  ;;
+esac
+
+# Read Ballerina package name
+BAL_PACKAGE_NAME=$(awk -F'"' '/^name/ {print $2}' "$BAL_HOME_DIR/Ballerina.toml")
+
+# Push the package to the local repository
+cd "$BAL_HOME_DIR" &&
+  bal pack &&
+  bal push --repository=local
+
+# Remove the cache directories in the repositories
+rm -rf "$BAL_CENTRAL_DIR/cache-*"
+
+# Update the central repository
+BAL_DESTINATION_DIR="$HOME/.ballerina/repositories/central.ballerina.io/bala/ballerinax"
+BAL_SOURCE_DIR="$HOME/.ballerina/repositories/local/bala/ballerinax/$BAL_PACKAGE_NAME"
+
+mkdir -p "$BAL_DESTINATION_DIR"
+
+[ -d "$BAL_SOURCE_DIR" ] && cp -r "$BAL_SOURCE_DIR" "$BAL_DESTINATION_DIR"
+echo "Successfully updated the local central repositories"
+
+# Loop through examples in the examples directory
+cd "$BAL_EXAMPLES_DIR"
+for dir in $(find "$BAL_EXAMPLES_DIR" -type d -maxdepth 1  -mindepth 1); do
+  # Skip the build directory
+  if [[ "$dir" == *build ]]; then
+    continue
+  fi
+  (cd "$dir" && bal "$BAL_CMD" --offline && cd ..); 
+done
+
+# Remove generated JAR files
+find "$BAL_HOME_DIR" -maxdepth 1 -type f -name "*.jar" | while read -r JAR_FILE; do
+  rm "$JAR_FILE"
+done
diff --git a/settings.gradle b/settings.gradle
index 819974b..11475e4 100644
--- a/settings.gradle
+++ b/settings.gradle
@@ -47,10 +47,12 @@ rootProject.name = "ballerinax-${projectName}"
 include ":checkstyle"
 include ":${projectName}-native"
 include ":${projectName}-ballerina"
+include ":${projectName}-examples"
 
 project(':checkstyle').projectDir = file("build-config${File.separator}checkstyle")
 project(":${projectName}-native").projectDir = file('native')
 project(":${projectName}-ballerina").projectDir = file('ballerina')
+project(":${projectName}-examples").projectDir = file('examples')
 
 gradleEnterprise {
     buildScan {

From 6960d8533b8fb6e56e7edc62cfcd4bb4bdeca0bd Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:35:10 +0530
Subject: [PATCH 02/15] Add necessary files run a Kafka server on docker

---
 examples/docker-compose.yaml                  |  53 ++++++++++++++++++
 .../secrets/certsandkeys/broker.public.crt    |  20 +++++++
 .../secrets/certsandkeys/client.private.key   |  28 +++++++++
 .../secrets/certsandkeys/client.public.crt    |  20 +++++++
 .../kafka.client.keystore.jks                 | Bin 0 -> 4623 bytes
 .../kafka.client.truststore.jks               | Bin 0 -> 1210 bytes
 .../broker_keystore_creds                     |   1 +
 .../trustoresandkeystores/broker_sslkey_creds |   1 +
 .../broker_truststore_creds                   |   1 +
 .../kafka.broker.keystore.jks                 | Bin 0 -> 4623 bytes
 .../kafka.broker.truststore.jks               | Bin 0 -> 2146 bytes
 .../kafka.client.keystore.jks                 | Bin 0 -> 4623 bytes
 .../kafka.client.truststore.jks               | Bin 0 -> 1210 bytes
 13 files changed, 124 insertions(+)
 create mode 100644 examples/docker-compose.yaml
 create mode 100644 examples/secrets/certsandkeys/broker.public.crt
 create mode 100644 examples/secrets/certsandkeys/client.private.key
 create mode 100644 examples/secrets/certsandkeys/client.public.crt
 create mode 100644 examples/secrets/incorrecttrustoresandkeystores/kafka.client.keystore.jks
 create mode 100644 examples/secrets/incorrecttrustoresandkeystores/kafka.client.truststore.jks
 create mode 100644 examples/secrets/trustoresandkeystores/broker_keystore_creds
 create mode 100644 examples/secrets/trustoresandkeystores/broker_sslkey_creds
 create mode 100644 examples/secrets/trustoresandkeystores/broker_truststore_creds
 create mode 100644 examples/secrets/trustoresandkeystores/kafka.broker.keystore.jks
 create mode 100644 examples/secrets/trustoresandkeystores/kafka.broker.truststore.jks
 create mode 100644 examples/secrets/trustoresandkeystores/kafka.client.keystore.jks
 create mode 100644 examples/secrets/trustoresandkeystores/kafka.client.truststore.jks

diff --git a/examples/docker-compose.yaml b/examples/docker-compose.yaml
new file mode 100644
index 0000000..6abf120
--- /dev/null
+++ b/examples/docker-compose.yaml
@@ -0,0 +1,53 @@
+version: '2'
+
+services:
+    zookeeper:
+        image: 'confluentinc/cp-zookeeper:latest'
+        hostname: zookeeper
+        container_name: kafka-test-zookeeper
+        ports:
+            - '2181:2181'
+        environment:
+            ZOOKEEPER_CLIENT_PORT: 2181
+            ZOOKEEPER_TICK_TIME: 2000
+            KAFKA_OPTS: '-Djava.security.auth.login.config=/opt/confluentinc/kafka/config/zookeeper_jaas.conf'
+        volumes:
+            - ./configs/zookeeper_jaas.conf:/opt/confluentinc/kafka/config/zookeeper_jaas.conf
+    broker:
+        image: 'confluentinc/cp-server:latest'
+        hostname: broker
+        container_name: kafka-test-broker
+        depends_on:
+            - zookeeper
+        ports:
+            - '9092:9092'
+            - '9093:9093'
+            - '9094:9094'
+            - '9095:9095'
+        environment:
+            KAFKA_BROKER_ID: 1
+            KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
+            KAFKA_SASL_ENABLED_MECHANISMS: PLAIN
+            KAFKA_SECURITY_INTER_BROKER_PROTOCOL: PLAINTEXT
+            KAFKA_SSL_CLIENT_AUTH: "requested"
+            KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://broker:29092,EX_PLAINTEXT://localhost:9092,EX_SASL_PLAINTEXT://localhost:9093,EX_SSL://localhost:9094,EX_SASL_SSL://localhost:9095
+            KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,EX_PLAINTEXT:PLAINTEXT,EX_SASL_PLAINTEXT:SASL_PLAINTEXT,EX_SSL:SSL,EX_SASL_SSL:SASL_SSL
+            KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+            KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
+            KAFKA_CONFLUENT_LICENSE_TOPIC_REPLICATION_FACTOR: 1
+            KAFKA_CONFLUENT_BALANCER_TOPIC_REPLICATION_FACTOR: 1
+            KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
+            KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
+            KAFKA_SSL_KEYSTORE_FILENAME: kafka.broker.keystore.jks
+            KAFKA_SSL_KEYSTORE_CREDENTIALS: broker_keystore_creds
+            KAFKA_SSL_KEY_CREDENTIALS: broker_sslkey_creds
+            KAFKA_SSL_TRUSTSTORE_FILENAME: kafka.broker.truststore.jks
+            KAFKA_SSL_TRUSTSTORE_CREDENTIALS: broker_truststore_creds
+            KAFKA_OPTS: '-Djava.security.auth.login.config=/opt/confluentinc/kafka/config/kafka_server_jaas.conf'
+        volumes:
+            - ./secrets/trustoresandkeystores/broker_keystore_creds:/etc/kafka/secrets/broker_keystore_creds
+            - ./secrets/trustoresandkeystores/broker_sslkey_creds:/etc/kafka/secrets/broker_sslkey_creds
+            - ./secrets/trustoresandkeystores/broker_truststore_creds:/etc/kafka/secrets/broker_truststore_creds
+            - ./secrets/trustoresandkeystores/kafka.broker.keystore.jks:/etc/kafka/secrets/kafka.broker.keystore.jks
+            - ./secrets/trustoresandkeystores/kafka.broker.truststore.jks:/etc/kafka/secrets/kafka.broker.truststore.jks
+            - ./configs/kafka_server_jaas.conf:/opt/confluentinc/kafka/config/kafka_server_jaas.conf
diff --git a/examples/secrets/certsandkeys/broker.public.crt b/examples/secrets/certsandkeys/broker.public.crt
new file mode 100644
index 0000000..490b946
--- /dev/null
+++ b/examples/secrets/certsandkeys/broker.public.crt
@@ -0,0 +1,20 @@
+-----BEGIN CERTIFICATE-----
+MIIDRjCCAi4CFEtcpjpBgELtRhMH0wWKPrzTmmnuMA0GCSqGSIb3DQEBCwUAMFYx
+EjAQBgNVBAMMCWxvY2FsaG9zdDENMAsGA1UECwwEVEVTVDESMBAGA1UECgwJQ09O
+RkxVRU5UMRAwDgYDVQQHDAdDb2xvbWJvMQswCQYDVQQGEwJMSzAeFw0yMTA2MDIx
+MzM5MDlaFw0zMTA1MzExMzM5MDlaMGkxCzAJBgNVBAYTAkxLMREwDwYDVQQIEwhT
+b3V0aGVybjEQMA4GA1UEBxMHQ29sb21ibzESMBAGA1UEChMJQ09ORkxVRU5UMQ0w
+CwYDVQQLEwRURVNUMRIwEAYDVQQDEwlsb2NhbGhvc3QwggEiMA0GCSqGSIb3DQEB
+AQUAA4IBDwAwggEKAoIBAQCc7D71QMmwi98ra+l5OGZM3UNPdT4vkJ9iUGo4w8kr
+mTZHJCGmc3//CE/oi+YtkOnDokNe0F5kyYl3Sq8jAMNhOYT6IBjR6sDkljqNx/IC
+mEiI10EgCS2oV6ntG5YWjK1EQh3dnYxoSfwbzV+HbvUwqSbhNRRqJQkH/vb4foY/
+VcXvjf2uVf5IjlbvfpD8ZSVL6fp99+daUw10o4MLbxowysWauZnPuFCy8UjDDYVW
+V/IYlEpnDHbhl4Gea8kUsfdxP/6XRB4FODoTkZX9nVdStIICqErXr9coLFwPVntd
+3eSEfu7hWvWtz3J7NMPjE6D3s/PwL+H9UR2x2niiU7MDAgMBAAEwDQYJKoZIhvcN
+AQELBQADggEBAMNRaAA3bkk6pAJ2bA9P+rj7IIMRx+PjamSLS8iWvDJ0BOANxMzS
+rvxoqGgbnIrNAoHSr4Pa5o2zBcb1E4pDHPqNS1SVDY1Mz/rGa291VKClxqzEd3n8
+7LDnJm3FOSFv5/p7fTlgW6IZGn9O6DNiwhURPcGwyTSmGtE+OcVyzugOOR0zH4MO
+GlfK3sG86M2+bTzkMgJDk99vTuogpwaddj0d67ra3TwCkma1Vk0D0MM+7Cplxh9g
+9msJTe5K7Zluy2J2KR7WK5uliXO/bwCJYgfyF0U8rBOHDd50BFxqujHybTZLKlaE
+pnbOGLjLOistRjnpaKbdzUIejaKd1NT518Y=
+-----END CERTIFICATE-----
diff --git a/examples/secrets/certsandkeys/client.private.key b/examples/secrets/certsandkeys/client.private.key
new file mode 100644
index 0000000..58b04d9
--- /dev/null
+++ b/examples/secrets/certsandkeys/client.private.key
@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDAk7ToFYTNSYyQ
+QGI0l2PxuvY5W/UO+KoOXLAGVpEXfTwbzoZT8VWSATv4ez6q+lTDo0pbYqbYRaNn
+5El+dEOFEMbHWgxhGmZVOmkD8wYT+3HD57NJVCl7tnJI2I0akjAqiiljTf2rD/Wm
+aN9yNTGsRcZaIv5HMO9dK+5yhCvVJ30NKD5fGYSkluIJsT5bYut+o9ZXTp20Z8ST
+vOPtAYrHaM4nUFzTVnEVJNM70f6wa6hMvzpNuXOY4BY1A3z04EB1AQe/9ECFV04X
+Dt7wisYxD1n1VfAqwbcWLJH+Y+3fe6+bYRIOk3LHO/lMEVqAEoMTkeplwGDB3Uh7
+6GkR/SrVAgMBAAECggEBALBWEC77lVEM6eMksUgK3/92/QNkyq5c0Aq6oIwNNGpX
+yHSF1caDk6FP9AQBhk61Tmyd1vZ7DN+4VHpLNWjPOQxdYkckk3VO4SllhMeS/pvJ
+gFCslySsJhgb5eYCNKKB/gzV2jQONBsxT/SCzygawVNHyOq8ZC34BxY/peXCVQil
+uYYRj8pYJhVLqZPt2jUJFENk0W/K2Yr5xHcvX4ZckeHGMloEuI0u/jFCYI4tPXSi
+0GyuUnZ2TFjMC/WEW5crbWEHZOZkskagdnlcU/QfvwwabXtJEPBfqjoJR3dwpbWa
+ORukAOW8uZh4opoH76c0d6012DT0jNK6FBHe46X1JLkCgYEA9Exd6KYvPGmB+Tx3
+BgtD8XVM9qK3a2SIJcU4Wl6R6ulYLqCzGh79I+mGFFEzEOGM5DK/syBQ5TR7ctTc
+Npt0tJm9XZrokb5uKU5CqafI4RotIfj7epOrjajIUCb17Ac4UkU/CMa9Cog9THzk
+tNwpaC0h1QT7/V1KntBVDdzwi68CgYEAyc0fdVVddgytfYgc4v11VvbLfjVr1xbt
+Cx2BwL3uyqUdNQnDI8s1MENhCQW1488ou7D1Z4DqX9QvYPcOVNAaaf3MVm41YBTf
+Rq6x9VgZW+n5UytuG3yvrrbPkt2zP06+/1uoKgTHP7SzOQdE+Q1Jpf9NRpqM8Lfx
+YXKjWN2pfrsCgYEA6nQf7BcRXjkjs76DvBkzq5eXtVuUDEz/HMCZxKDeCUTIjHdN
+a9QxvTVwqC8Fgz3zqU3LDG4HNPGZSCtg7EdlSa4CPsNcUAMiViH1eDy+XMpyZhg9
+wPXXvqwtEj9R5KNJOiuawyF4a5M0wSNbmvdwBbrKrVWLQS03YBMwjY1sjaECgYBr
+4sLnurydqQdzbjprTC/YT1bZYXwG4NXXtG2y+pfYNM/ZlB+EWlZUOCF/blMguJbB
+SUjZjf0/QDQYNdyukRceBTaiGodkl6QKqMixLulXz02hHj3eahmOYWO109rJhLLt
+2DWeSTGwqE2Mtos0TttJ6KSKk4O4Cc79VwlnMBI2kwKBgQC7FfnLYhPZ+QrluCYA
+62rs+BNI8QzoDv3btY0skn/MueE1py6lsUX1BtaV8AKY6hx4woQSCHx2zJIg/FhG
+j4nMlYSlPk5heueSG19jznS/ASPskh0BbVGmwJgrIMc+643LA7GJig8HlBNUvtux
+jb/DNrHu4wWp5yxqS+kJ3VX4Hw==
+-----END PRIVATE KEY-----
diff --git a/examples/secrets/certsandkeys/client.public.crt b/examples/secrets/certsandkeys/client.public.crt
new file mode 100644
index 0000000..810e573
--- /dev/null
+++ b/examples/secrets/certsandkeys/client.public.crt
@@ -0,0 +1,20 @@
+-----BEGIN CERTIFICATE-----
+MIIDOTCCAiECFD9o08xgwVMIpyIrzmWt0an2DIrsMA0GCSqGSIb3DQEBCwUAMFkx
+CzAJBgNVBAYTAkxLMRMwEQYDVQQIDApTb21lLVN0YXRlMSEwHwYDVQQKDBhJbnRl
+cm5ldCBXaWRnaXRzIFB0eSBMdGQxEjAQBgNVBAMMCWxvY2FsaG9zdDAeFw0yMTA3
+MDUwNDQ4MTZaFw0zMTA3MDMwNDQ4MTZaMFkxCzAJBgNVBAYTAkxLMRMwEQYDVQQI
+DApTb21lLVN0YXRlMSEwHwYDVQQKDBhJbnRlcm5ldCBXaWRnaXRzIFB0eSBMdGQx
+EjAQBgNVBAMMCWxvY2FsaG9zdDCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoC
+ggEBAMCTtOgVhM1JjJBAYjSXY/G69jlb9Q74qg5csAZWkRd9PBvOhlPxVZIBO/h7
+Pqr6VMOjSltipthFo2fkSX50Q4UQxsdaDGEaZlU6aQPzBhP7ccPns0lUKXu2ckjY
+jRqSMCqKKWNN/asP9aZo33I1MaxFxloi/kcw710r7nKEK9UnfQ0oPl8ZhKSW4gmx
+Plti636j1ldOnbRnxJO84+0BisdozidQXNNWcRUk0zvR/rBrqEy/Ok25c5jgFjUD
+fPTgQHUBB7/0QIVXThcO3vCKxjEPWfVV8CrBtxYskf5j7d97r5thEg6Tcsc7+UwR
+WoASgxOR6mXAYMHdSHvoaRH9KtUCAwEAATANBgkqhkiG9w0BAQsFAAOCAQEAN63C
+qU5wEhLlucUhY+zL9hC7FGuKfDaIq5yudigL7Ui2Ab2fr7hSf6TcmkXr8qAXNHpc
+CfI9WdxyVzuweiEBAat46L/bVHtsIoIYyUEGtt0aIRT7ojcAyPNX+G0aT2q18ydZ
+pp1VWzYp8PxBhSHqZlRj9Ake78rH64qLn5XCOopiSI4eocSVHKAY6oBojMKdbJHF
+8MgyMgDlkpQyBmHTpJk67cyFr+BOjuAVo9EzsUYqImrIK7sLAGx4V51/8bzt5UfU
+HCWW0/tCWQAzrRU2rupndZHLImPzy/tGQBA/61ICDa80VMVggmQkzo3FjtuU9PCY
+SFeMnPiWSaMeDTBKZg==
+-----END CERTIFICATE-----
diff --git a/examples/secrets/incorrecttrustoresandkeystores/kafka.client.keystore.jks b/examples/secrets/incorrecttrustoresandkeystores/kafka.client.keystore.jks
new file mode 100644
index 0000000000000000000000000000000000000000..f2edd525d8a9e68ee4b0c63f88f785a2f4b2509b
GIT binary patch
literal 4623
zcmY+EWmFW5wuXnH8%dFn9@-&>ZjjEQMY=;^0O`&Fq)Qs4b5K&cyFsM8LmH&dckjCQ
zoOOQewby#yckiDMIG7L{h=dFde$|VH$r>&nev6BQj+7Vtsvafy)%SmJ6*w5x_P-+3
z4=BN?I{#qkKck9<{eM?DSV+LUV3Y@NFv=~M1r6)}@juTgP>69Ck<012KkgB(ih|@<
zql5TmjY@&YfF5;}V3ff(MlmP>uKEdtmRpBg$|@j{Zglh+_N29#{klX6?Fx3B=zEdu
z3~|P9y5GG+_F|Q+7bUKn;R^RFK%RLws2i1H9k-aSgl<Q2Q%*>B?}{0V9bcXOr9ef9
zHm?n0Rz8wuD=4*rrAekI)%?$sbLi}LEYREE%`No@GFh}jkvs{CGj^@k(8+C104g7M
z6FQJrTDJBrkmsO-NuU~P|A#pd;qUIiB|<8+PmaxqsU~RjeXy2jAS7@3eu-Ck-<zLR
z{m{Aoz4e0lqW&Aj$UOX9=P9sJdS{D>EBSmC7Z6;2Lyh<)gUp5wGoTD+L_A9?5jEVg
zs37(nHKg;2Rhe5)(RzXa4RTr;kOf_9^!3$@472oQkhXHr?H{%oIx88p{7j2Q|AHZ5
zv2t&3s#V8b-vs@vv?jLWK)&A->uHK+(v|TZSC@WMlTBQcfeaPeWv1}*@h7jfz=6n=
zF$BNdF|xd>2mPM~vfZ44QIw4VCggbHocurSh%K!cSh5ZC6wi*AW5ri*pv~Tp_Z2|~
zs%+4Oh@>O%pgd7Hg3rdyA~F7FK>s$cQ+;9T0H>4=OpxC;dm;0z_AmyU;8B*k_a<w`
zqkq$SDiBv_yd~;u)h5#0A-&n5TF?6RLtp+I(rQvE-8&VED@!4<i4Qj%AD$GP%7BD}
zHYdFZG^7`Et<<2qYXJ<6M+8o_-E=^-*X}_#nu+=Zzmo=MNXl!bYe!9wU#E|OU2TSB
zeXrkcy381OeMn<sC!I6T!7C7|MbnQMtY)H-PjM4b<}MEnZ|-z6WR~erz3mJQ^6_(J
zCL{K<#C5{9S?Q}b;CPJM$jG7H8}Y4~0~2M&brPmL#e4`<46)99qm;Zz+QEr74JVW(
z(a7)CztRy?)P_&Nr>2qB;sB($CALWX9v&PlzPU_eYY8Pi0K$!@hEaq}HN^(IJ9$HL
zrs{gevHI&TI|__vy%BtVcjHy>3VpJv6A5uesNE1~{jevxo27em*#oIg-`qg|#?K+^
zMQjg6x7%A*if!lYACN9tEM?l<=N3*hiCvM7SGi3;Pp6)Z40$L^i*p!TsdsX~zx^^^
zi|-LA%%#z_?W8Hl{2|+mML1X~-BqAcEWQ7QdNC>~hNKGg?Kfu155t|0NW=WoStpFg
z%XaR77kpH2(Un)24Y?U*-jjotd;ZM0?Y;II_-m>|vItAfbBP0-GBrFbNh1ge$fH41
zt&F++%{Frk`P&nk8BvGAea7=|z)41EdCn`TVPlw@eLSSN)?8nsK8&FX;|JV|3>7o3
zW{>8Oi((qWXK6p#CJ@0C1EykhV4&dR8+YG48~S-K$CKKlYO*P2_jw7uUHgd^MW>Wp
z5LnyEd`kvHb7SpI=eq6F&Sv?=wB*kOIrP0=(6U4z7dIVrr^DsqUR^h@JcMWRn9)mS
zF>+|pH(vjgSy(CIWqQ>1lHB=w?C??6qX?4{)PrUlO$3h6T@@W0$Z}X&`T(tRZe{S4
z^83~YOu8LfyYLO|bZ62aeEO;qX*=UqYiYNuMrWAtXyJqRakTr}@dzuhvc;Y$w#l-d
zH+q;8<Bl33R43>6ef2bt$E)rguT{<3ba8NcvXkb0I};r?jIAjv;uQy%1eoIAs>CGb
z!lT9km;)RDwg5|jBft$z`=5}6ix`Da%l4Bc4HqAeAg=%y7ldCxkPjS;Bl7POI$B;Z
z4#z);1&9RrXVLv9LHaMlqWzCyeF`zDB!*P|<vrTFn$cMyx@D@m|7+O5VC?;fp-&m_
z%Z1{pk$8(2S}hyJ*&Pn~L2WEDM@Cmm8a^DfYXJ1;_`Q&Qmgm_SG192V7_{_WJIwRX
z!#RZFv%GsV-au7@%Yn7FQj2-nD#;h6khx}4QC1$RVl;fN>aGdJ`KU=9L0uL9)!3st
zLyOwtzS}*Dj1G3SFRN@@ru!4|*RxaH+en8;Oecc4SJgVlgEI^W3pyr-Bb&vGy$dD)
zKI-$D3}2-5+YE?WbP8qQFgv=+BvHZ`lu`YA_66ZEXz0$w9ZL=bq|dO{u*;4)yx4TA
zd+<SNV(fZX6xp-qGD<JMGJ~<)KdGVH!6IF`)08cX5|o-I?1Yjm|Kd_2g_Wpo?~o|n
zcvMUu3W1^a5ImO2(2vA3>r6!y?OKWcm?rEVH{kqaJBL!l?Acn~Cyw@>zeT?}wd<{9
zMZ-rG#@5MQ@<Lom$qf#N0r%GsB;3q^paE18Y;`Iro&=V1l^Gul^|2~{OL-HWXoHx(
zxp0eE|D9i<dDd;uZXViGC^Ikpa_dNgxAeToz<nCRFo)~dNm(vanU2sfzXsxI$FBr?
z>KX}KL)@3v`_qDID`S}ExUpWD`{wsR4RR{d%^XZp63ZhKiJ3pFvA4~SB0vuWG4c>N
zJv7TKimM9I%8ezGMnT3yv?SAI7~KncQ^8tD<<|T=lGw(Ou(jT1*U<tI_p0*_AimY2
zIe#ck01`pNXXy(tJNJTR2&E-}093NgzzIfezXPHOt9Fa&`zI_Ncv=~`*D|w(DZxC~
z$RN82^sP{;|LX8WYYVgUuv_T51M~oqg~kULi8Y|9FC52l)x!ccn?<6lBH0jV@s-c_
z*=>ks!V|3I$m_|Ku@Mp$HJNkZxHBxR__p^$0;1hb(=myu&bz6eZ*4%8DL+1(30FqC
zL@U4U^I_QxNPs+reN_7CT}(~Rsr9oeu%(}E&T}6&^VL?_$kbXY^<B@pd_c1dFbrgE
z7<w>EDz_9~V}JE9jKq{=rxzO!qb-Q69Qocd@+GKw{nH%uBX&{^Lu1x_Cv0|lv<K<$
zjOGQlb?q`UUg*irw&;G5(rk6ouqOU$GDmnt>0gkMr$~Wa_gq!OkCL;9KbZVaUo}!m
z&W0~bpCX45im+g%b_vyq>DJ9yRC4dEWV~K`QgmTd&or$Y;pl^WnmUVdknW{HIZru=
znw`Pb7Yg05%C99;z4|Dw-T^mG+9A=`AQFSm)YDedx+X`RO1czI(T*@^RUdIBwF3#j
zWE^Nw#L5^I!nQeC)IPjhTu1aSzq~m@xgoU5Vi%H$9gj<&#5ChB$nf%)<9PRfzNaaf
zJy%UOCcl(xV(i835#IHX08i&RuI3sSt*C7Y<!hB~hf$>d%8ic`UduQO@5Pa-^QaVF
zBxrp$uP;h;0IIZeUvs+f8Un3Yj~{s87TW<7UHf!T18o&5SuQEit219>vhWo}{t)4I
z6?NCt@>&x!0+f#SP086_MS7p}MP|jhxA8A|Uq~mE&!+_NI+d?^bZaJ1FV}?&I+8M#
zbbCE6#qGM-Stn0k%(tR0cgTOf$iX)~#=|9uERNlV;#D$gZjc{Z!yDF@YaE}q3CVq%
z)Sj{0ow2S1GIP7($qM_i`ttqM-EI0A#DMN~C+0tFj9A0ZI-n*C(AFM3gHtFsTBC!A
z#8XAr@y{J`;Rwj|m5&Mn;!z@hUY|npKsqnjQ(FDSVYs^~gForuWhdEj#s1g5OHicj
z46835UkEknyxiGlqK`~HSsiLbxkM3R8wtD7d-rEsm1+mfzuyHaH_p4b26RX9AD!iD
z+E8ChnIG`V)7{O*RDG8b65)Zsd9o&K3!!*g*-gs__4&CJHItOKpbkL{o<>N9Bqn#e
zUc=-C>y((ndu_edp}fz~H878(EQOZ2CLHiQvho=fGObHs6l#nl3a2%4H`Ltc*vta#
zD0>seX}11lad=EgT97Kk!FLRn5KJ4NU?;~cO8;tmj%;6~vu@5PrfB0JKZ36#wHFL!
z$EoDk6<|ib^jR!TzJ_l0ypk4jQ(JeQw(@vTu+RzorZ%p_xF;(DfwBGZk%*SLNmpIY
zanF*AKefx0<z&CUJ)b0@@&=yV_>9t~M?m!OZqm=Q*VCF&uTm=8vVE4Yss&r4Ka0XS
zqzpFpC-UQ;bnPGsE_$U5Q%Tn=rT6`5)*-55ksaTvYO<pF?#?}3p^Xo=oD>3sX$r=4
zu1(b4YrEDL?<>%S!!+IT?YDjBz`DD}bo*uzCuiJxAJiElvGo8<7rn`hXJH(z0R^}j
zT~8%@I7IB?&kBKu_H-Lf==6lYf*E`g%}ow$9`uAgcP47-l){J-Bm!62uaf;|DSNjz
z&CvzJR|THBVij!%PNe*$oU29G=7ZbAgy$sK4@Uohi%-fJBBfWDc}dkPWC}L1jC|J|
zbFA!Zw=X$y*}jcCX7(X(52CN=!lt#cU&HD#Mpx6LASjwP<p~_#!3}W9t5|q+$!VYb
z%-q{N_1+pJvsNcQ)&*4>?+7Bf^`}3<#HU)M>oE*6$b*tc6BtiqGXWK2PxvG2jiWky
zk}xq_j#WOJQKrI$69O-%Re<_xegZl5@1za-1Yh`Bl8<aK&1=(6J6FP9NczZWdPH~|
zF6Q=hTqgDF8BGUD*4pZ?tBjvaMA-gH1167wydO|o;@3QB%N~bm1*cdvEDcNqnyPIT
zp#$zNDBD`C0TkL}TwvJZN1W!6Z1Y{Ayxm+%H}n{F!^9QDZMWz=i{CJ62kZ8p=!V(*
zp%#OTsvlIc6QxWF_M+*=r=MQ8jP)0QLO<Gi97}Xgs95Etggip6)hIWPm&vy|HTuWM
z3zZUoP_h}l*26Rz^zro=Q|y=f>w8=Oy^^Wf?byMg7`}NPZycyIfOB@A?#hGT2-D`t
z4RsH@VcmUxdJ%tSDU+{l>@%K{beJcU$GLOFGl4v)UcVHX)F~zklNjKse}R=aJ4%!G
zJ(DC`_Hit|`z=P)T8O~b2jo}s{Z4$MB1r%kaHce*G_zdkM>>H+Mm5R!Svu6y%6~o)
z(&b?MT^Y!OEs9RAVyZ7CFK)~$98cvCxqTT<P+!?~=*x1f!WjDN5?n)I+NR^W32{4y
z*qYRv)H58DRfE1*Uq(GQUU=W>(x;H(dXDN-4l_}1tBH>go?zRxjd-X2tf16?lqvQ%
z8N?hCEz6e#i!l#dA=lI$TGV#7k<Dmpv<1Rh@d@ERZzz#H-w$%X*CsHZo>9_|`P84d
zfc8QWA=gVcpVbftsF}ri(HzA1D^9_$XG&~e__<2sV{FCB8%32d>B`^CqNk{j=RZTy
zKiyCrHRQfQ-{}+JLJPoIm7ORlvD2<1e^+(Ti2g9tBrJ7viehZo2wUhqC@t186c8_M
zaSpllmpq1jBR<09*jWnN_dn7i$}i{@kWV%JmTm7BBTa^!fw<uCz0=NAqaVBwE{unp
zL?*bd8F&%lc>)|zyZi;h<XWpFVP1*(d`l7vK{!?MUK~EfanOABYwuTe-<eFRB*F?x
zyw0?>OY=!}4ou!@{TSyNX4R<!sSuGyI66Qpxf#t|Tb4yI$B^z!SCx{~>)%PX>wyMK
z^B!I<H~@?CocyXft;7NYDoV5b=vM`-QKa!hGCS6vY{Tri{k4)Mt~VUqKndB$JR)`C
z6Kq>9EWRTqb8=fz&+o8UTAR814=KVLRlc6z8_;B?h4_p9^*}$#$_Rp{b<8D0^Zh)d
zNRaNjQBUs%K80a_6XH(1rXM{D=n(VJ>N6VI)$;51nVd0OnlNG7j`+x&i}Lvm-G&7d
zHSx2}-+cD%qX`tm(8(RAg45Qo*8_K{K*=fdv_|Fzn>~pRjq<*3Ett&*yYOId0%tSO
zjx+*F!o!%U4V5%?(tDLGURLau5?;qZ9d_;yU6s<|<*iGVh~Ivv>G$3`T+b!**FjLb
z;{2~la$alYu*p%!A7*8p?ar9@<fq>;qVEIV6)kJGsS^PA$j7U@q$qzNq`&J!JF|0O
zs8cRedatrp3Sid1&u9u|7C2PIS>)JlqNc%OU|KLH8Y&weGVl#50EKv0-eSw{QCmI^
rKz%rm_BDJvHGCe0n1JZ(SrQ~7zvBtp&`jyg$vaWf0w6L{c;3GNSizzD

literal 0
HcmV?d00001

diff --git a/examples/secrets/incorrecttrustoresandkeystores/kafka.client.truststore.jks b/examples/secrets/incorrecttrustoresandkeystores/kafka.client.truststore.jks
new file mode 100644
index 0000000000000000000000000000000000000000..aaa2f68b8522ae2694a953d1475612184677fe48
GIT binary patch
literal 1210
zcmV;r1V#HWf&{h#0Ru3C1aAfjDuzgg_YDCD0ic2eU<85$Trh$JSTKSFR0atuhDe6@
z4FLxRpn?QNFoFa@0s#Opf&@AS2`Yw2hW8Bt2LUiC1_~;MNQU<f0So~KFdGCE>_6jM
z_FJ2(WH6*Kx{f}<aQb&*0s{cUP=JC20K?b(6Cge|fU+qQ>MTkUs#K!b$+pk_HMYVx
z1oeG4LIE|kfUk}uIjf0MBGrD}(DJNx*WWs#!zUJ5o&pWtrgx@Uh%($&cw&z&&@otC
z2M4u<LFi+>heIMBM{^G?6cc=OFTTNTcSQHlZF8Q&csKS<><Cd-fGDH2BG0|Uxs9?^
z&WToUp?(J=sgA5u5>X}jH}#}j*C@ZxCyl*sNm$zAt$vo;BK8fe%I7j;kQvyLkQO%}
ztN0?pU_%Q1XXk6|I@dZdR(%bJ!$!J~>3kX#3DY3Dtd(eJP4!gGfa1xXz)w&*f^vMK
zGo&b1=Mvof0G#Qmo+ipr1P_^n10NhfY<Pz}aUM*d;r^-UVW+Ws9ht#aRVwdu2z*<c
zK9+JSL<YPnQJGqze-h5|m;dKa`-l`^BhUC*>gF40iO~I?bY!hiR=oRu(2|~+aYtsd
zK|>F4c9vzfUS&gPQkcLFu(0QGVY*QnvuqL4_KGLrTCt>d>V$h*MIdb*upK@9$(VO7
zvhbr$^Nj8I`eKJNOvKou2i8K&Kz)|O9};iZiE;ObDsz$LbrH?`+8(SXNrF)}$ADJt
zcKxNaB?4;?i5fV6Y<jzDzyBffq;~W?t27naNVZ8aGg}rlMNJ_9SB`9{6ZrsM%=_yK
zs;sa;GI4nmf4XWSg!FUaN3T>IkS0rPM$0&{zHp3usZH^KK@hLW!F2mMctggKYHN2I
zS5tDEcF{YS>xWs9yOX9Wb@kx&jWTJD|GKpLW$ht(-Z8dH@{!GD9K~d~hg@o$yE0pK
z5VOO;^}Bonz|zL0ZAN@(fVEtBy4I$gykh->o+#JhWr|g@d~(idQuP++(KmlmhlR@w
zULG-`J9Uam*iM2vmAx4Dx{CfWX2N|*?>$~r#O{E@2$g7iQtLh1X9WI&v?skIC<=3R
zMz$<oRea+2@dggjh5y_jr(hM1Jh4$zerdMKAEI);8s|i*Zz(%7q?2?Rnr3X%bx{Ng
z2<#$VW_1?88rKAm6w#fc=7wzn^BX7By{ZgV5jOlil=Kd<86!i$qDp{_I`lZ&%zs)>
zER(dskw%6J^jtuwX#wWTOzYj9Ldm;9s*w3H0Gc5R2Js~|RuWY32di#spGxHtUM)}K
zv8InM!%JG3@o(pkW*>rjcXBvY6`xuz$3|#V=HMIqIk!ZkWiBv6dh1LrLHG(FkH4=B
z(i)6%X-Ay4p5<~vZakKg93k-egLW?jt~;D~M2@r+t4kB?mBN<^#BWj6W*9L`ha~fw
zffnnrWYc*kV|M#eAs#Ug_6{;rZ(T)zk2!CX@-J385njRqq7-)%1X0T@-nW%rI~ySC
zT7?H|)AP%5%`iSNAutIB1uG5%0vZJX1QdU|USHijuf7MX7?XIE_LuFWnQ;UZ^Y^~H
Y6-MXHE_uIfTh_r?74F``0s{etpzI7RR{#J2

literal 0
HcmV?d00001

diff --git a/examples/secrets/trustoresandkeystores/broker_keystore_creds b/examples/secrets/trustoresandkeystores/broker_keystore_creds
new file mode 100644
index 0000000..f3097ab
--- /dev/null
+++ b/examples/secrets/trustoresandkeystores/broker_keystore_creds
@@ -0,0 +1 @@
+password
diff --git a/examples/secrets/trustoresandkeystores/broker_sslkey_creds b/examples/secrets/trustoresandkeystores/broker_sslkey_creds
new file mode 100644
index 0000000..f3097ab
--- /dev/null
+++ b/examples/secrets/trustoresandkeystores/broker_sslkey_creds
@@ -0,0 +1 @@
+password
diff --git a/examples/secrets/trustoresandkeystores/broker_truststore_creds b/examples/secrets/trustoresandkeystores/broker_truststore_creds
new file mode 100644
index 0000000..f3097ab
--- /dev/null
+++ b/examples/secrets/trustoresandkeystores/broker_truststore_creds
@@ -0,0 +1 @@
+password
diff --git a/examples/secrets/trustoresandkeystores/kafka.broker.keystore.jks b/examples/secrets/trustoresandkeystores/kafka.broker.keystore.jks
new file mode 100644
index 0000000000000000000000000000000000000000..5bd0ed7ef5157ff92d4a47172397e325661a538e
GIT binary patch
literal 4623
zcmY+EWmFW5wuWICx?uq6lCB{|8AcEg>F$tLN@f7*7zPPR3F#c#p=&6mQ;~3}A*Cfn
zDG52>z3bj{*7>p5Uh8?^y?;JnBpo>bp8$-c9UvkVj(!$>L5WX{UxcJ>0U~J|{=qe1
zB%$knMTC|>B%$d)*zljxB_jX7D+)4vKoJsn4MqYlz(Pc1|BwH9&I$xcYPIvuL5Mfo
ztx0eXaSJj0e>w^P1bF@WKqPR)@yv$qLiEU$n4jh9wJ?=mvGd<DI`y2e9;vvbp{Kv1
zcU8Kyd-5<B`;j6p{16$~4f%_#{Rox8*ZA4i!Cb?&F7w)A4tM0Vic&xMHOu9zwH=<S
zxtgr@F*E<Lz>Pi@hjCa`0y3_#+%y%G!Sn^iZ&>o2o2g$l00IZEh%F?(kf3?mlxp{H
z^-LnHFOZ@t3rY*u(B`n4s7=-M?~<j}`t56{xTc}HwYP%C4VTv8V|$1;LaFY!@padm
zQuVJGTwURdBzKbcHm|x0b{$17JM+`e$KJGn=%m-huh4rXuK`c(RPu`~*1>%29LCwe
zR8GjveXEcI!~q4)qOagRwXO_L(QHfmK-pvRf_jJvK|YLE)`Tqyf1YewN>XC*Ygp7T
zU|%klaj>K_H|wNK(@SZ*_qP0jU!v)y--e@y2vhR>i7b{WRJps64VI|b1&qw%{>|a~
z<}HPvtJ&rNl$V$IluLZf@pNXSYo>1HPx$nrsCW%r(*xjsfN8Rt*o&(}$l5RQs4`64
zE%zAT4(3<1vo2!x`7FD7`pvm2-}7WafKw@3PO?k<_t5RBmA`Cw;<dL{(SC(i1sc<W
zhn2NN^B<3JESLK%zmb34jLa7zCjw<CEP}p&V^wV*Y9fL!-r5|~8Yg!2{0@%UakZX-
zGvl>eklz(vu3qxAxEabN-8jH+=V|Qt0XV9fN*3{Zv+=sTU#20^e_<iJPRDYk6gQi`
zKdHX{Z7Qyb24*~}7UY5y8DIU)8{6NQpW#P$@3s*$*<d!pUF7O|<vr4DWrs(`ArLtD
z1AS^7>yP?e-;+xV*WCCSg-GJL1tSS6p?b#h1vxEJ&KJnnh;J2Vi%IEgQzBRdrM#O(
zl6lw%oL}}#Y5!s6w!v_?+$mqOS_D;%-*S9BuHyd1Fa4<Ct=4lb^R!y2Tuff<GxfdJ
zCl@dOjNVzCzpPfrxw{X<zG@!b-NLJs^~3a$c}lUe+C5ygR*rhdo5n_&_zQ&ExHs8Z
zvd0P9r!-b4D%TEW5334Qv`K;RzNUF04Go>?lzkQ<ec?lfqtT5f(#{$2N`!iLR&K(-
z@_2xjcRt%zoa=5YCf%)eyqc-8T|-Ot`Gid7+h-&f7?YunxvdieXD7kv*f%n7`I++Z
z>zt@y@(O=S{PTR6Eus{B6m5;XKu(htE2x#?%(c%vSw*9~KbuGdYBHZQJCfAEs_vk?
zmcoTclk^m+S*V_G45PG?_*ZmP`vz_ckMcIZ=12NBzsenP7ABI*6H~fb_kVJ?B-0!>
zN^u2~(r;=yj`;y;mMdR#Oxv>vHP=$yvr5#F=M|`^2;(Go`bC}NdqwihCt;JmF?H8s
zie$`GXt+2VGG7g1^ZJW>8%gmAniBnbe)dLcmzr5gR}*$3S!h*Gsw?Pu6#~|N%+GFF
zp(^=xq7JE4BJka~=tXSXWiQCm@I(DP-uC(QLYlfwiV?f_*;Wud$PyjW9P7^=xr%-3
z2as)i6kg&{w@GqAqXjCwo4gCwG)eiRxinaVQh6zg4RSSDn+F}UO?NL-Q`-`lEsdk-
zy$NP8in9ReJxh3jU^xw8X@;hc7~#!UEyxjYsT|n)(J`e~@uPrxXLTFku0~5z3C#L$
zRg!`vsW>R`9PqsHyzt!dobkND-2Vv~BtbwrV^>dSE=f5lDLENQNm*%0*@s{x1?1l)
zVxl4>h1fqx2!N0G&*J${g8yHJCHf!3-g)sTj~2h4!_a}ofJMDlogVT!|7%zTl6==0
zhs&$<|G-z9SmlSmPxyFVy|3Deo^-`hhIhx?N`a>*D5&?6$b6nOG{^{xHEOcF7?quL
zztbwjvihr@xI5NMWp{izJ@kShRqg-C9E!A#6*WW<x1b(|dNkO01z&10sh33T7F0uX
z6RZad#Kx528}S~_lWW-wJqm~{nkyomkN~T}aJ9&pIwRv}!?OjSzl<wR7iRDOA|Kwu
zjz_Qz5V$I#Z+>2g@p0IWuxD7kcbySdwLPGZ$8`M|3}7L@x8-RRL>02}K;;~mN<-(s
zDa&NrAAUW}R5UymT(l!fEWe^%D^fVLSS$FRn9y*lDy6Q&Ql;^0gfP^^_;i}b$G(EO
zg|dzC$t37e707yF!$&};;nO>efFDpq^3D=4aw;@?Pfka?;A2H(<$9T&u4iYG8UuS<
z+B)Cpw%l=T;m|!NZ<6~t_^+vIX`bl?-{~d&nOV&sFi>_}3d>11$6|k+A2X0-<J&u8
z0*iZbXXjlUINvCV*~<3SwY}pCcK2NWOkS|cIcw{RsGdvZtKu==V)tV>FtRTqS6BtU
zjhZ|_)IPMvH_7|s%6JME1?Bt-RfBLoVD-l2oSe4WYe~^srdeCTVbYwaX>N0GyP7Yn
zccift2c&l*ArNQyi<hv#G%5Oc(&l?xG@MvgYHK#ml*5Jkom)|RdOnF1r7vGYhaK%W
ze578wy)S>BsR)0QVI+terFgUPR8M<(g{sX|j=Z-70IQMq`Xbu26801d{43<eQ`Iza
zE!KWZC8(PD@sZ@rjITsRTo<9GrHK(okMjI*<Pal4V&n$)0uHS|seaMs7HS-ItcESF
z$#qDmsB)(=2epQTlx|Jhue9Y{B^FZza=j91JdTlFw?b1b07Lj(CT<mY)~r+pZ&jc#
zFpQCOIhO*Tlik8dJh>nb?tyCZ5YYyVVdIe?H(B&U>4*6<GVMS5SpJ;l0{o`e%InF=
zu||!H;u=3oOjemVg3MoP;C7O!YdSl00+4L_QJ>?Uq(&X4xjSur`tFN<m#^yC{i?jw
zA-OLbdMwQ-xJI_8<S14km7NwJ;dLQAORnm4)mZh2Z?$e;%nx(1*B>a#Y3j;IgiWz_
z$U#s3DvIeDFRo7KPtvOjuI5F!OLe_$lwsh?Kj(5}*oD46=7j#pP;hS<|29$x7RCg7
z9NXme-yNlmuim;KB(VNFiYR9Kc1rI)agbAQ_C4adJcz*<+3n2Bhb2()es!OIgWV3`
zR*wyp!yNKjm2f3DK7i%XBr^ZU^V`c3=a@ou1Ua-xp|n@v)i5MtoL7&Xy`TqYgJ1Rj
z;{%~J$kXLU$@&7pjmimIHNB?6OjoI7E-CbaI89<5J@8o+ip9uZ67SSqRwY|J(cnF!
zE89)wVuYdKo}0?7e)h>Tl>M>OQCewnz?r(;+*^5vb{{?sA5QMd?&jE{IN49*nc1~+
zx|TjNGH~+yTvwW&AL!<T{dr5Yj*S&+Beab>*dH4!>IUBbTJ3zlvDHh4o3Dkzz`ir*
z{_lW|!Eb)2zf;q_^CmSjCjx%6Pqvw(5<l5|0a>MH4G-Nv|6aMr`(3UYW3F~X=Mefy
zLoqM(F$kt{asVAepl3jSsmkKZB8$P41<LS`8u=z%FMjUcS<6PuN~_%$=b6tcmBE!s
z_Ub+F9k97eHfflw^Rt7`=6GRauLZ}+-mV)${x)}>t7ZFwI0g|zUUD&>E8@CGirW5j
zVF^(&eu9X+H7KLQO*Ny&#n=!_eiAC8XEP=$|FF1XRwF@uNtlg|h^4C+Gyvqf)lqo8
zCoZ(t&@&z;%#3y(B4X#`xjl#mz!5U5smESI{W{A~%dpYYd9w~S$`p+R9op~UZQ=R7
zY?vgFl6fi)Njf{{#uSrALz+qQ<z4^T#(vqm6Ls5*w*9|!_3~D5ID`+xLBZVJ2y%%Z
zyaODb?nu)L8SC#15-J!GCb%uU$=tB;DX>>ELx|XD_`8c(x*RDAcgkD`kUNa6E~%&7
z{2?{hspD&FERIdLYMGc&Z}WY@LvSt)!vWbIFk&FlDN5%y6NBYNWZaOi3nm>MEN!lQ
zamSi2&Kiu5m8UXYEAHx!_ea%Mb*PFNH7cROpGP{#Qmpc8i1UsLidKu?rAuZRNsF6x
z+cgsO7~>OOmM<wTEZI00CMC!f<ucAEli&6XSXSRv9v<{v{cUtY8Q7l<w(_xF4RWA8
zyt0#}Fo>SANwF{KwNhsM#kL1y$z4l$L2;<E)^0ih^A4KIB~z2JUL^OCyV!Pk0mJO?
zsdD>aI8M}XZo1%e1&6Ax)3P?5k=2OK&2wDLv2C$LRL>R5!unCIw{^?mJYPTy133BQ
zWS#5-f#E=Ijeg@DYJ=IZ9mZ2q2QehYk4GcJr|Ep$5)y+n<J)fuvKZsJVCo3#_k??(
z02-$vGf(}<j`3m4bMV33HNhhmW(1Kim-Av0SFaK0m2u;dVf5hH&2voj960FRThCRz
zH+m`*;x?FKk30(i`8V*AmPPv_j4(tVTDrWFOf2F1=ForX6E$_|%3&%)AUf9F=kP%o
zX|`h$p{-g1q5Cs}YjQ<n4aNz?ez53=#H~BK9Q78{Z7#j;2?9(SeU_|cIw|1igLY`=
zm(vYCYoBOuqBWN+zBxC8Qn)#Q)MhG3OnYFWmO`KR=iBvL3ewSj_IX8Tl^8U?UGnrh
zdh1o+VdU}<J?=SihX{w;zJJ-F{FK+{GuA2gtF{Ew$#a8ct~5pgeZFWbQr`?@W=)cj
zCE53*GVXC4>^yNuOlZyIDgD$!c_eMXM5e);P~I{23p&B(EFq?GrSl*>@mQVWbhAtV
z#ps+s2232Ugm8u-NH}dC?H=hM6o+3)N=I$lBujFb3=VE}vYG4XXR18x&SCZ2{rkeL
zp2>f6HC3njsf@4Ec3=X6Q+%Ux^`@3aejCp9M4a{7T&8-MDr7*$$z0~|<+m2003ab_
zQ`8mFH*5uqD{L&Qf!hJPG+NCX8&@`&?f~<G>g%Th^%Vi(ZlVI<S15{GSyhRQ{+V8~
z>;5fDH098`_?%*9L*n5R^u4aw>nk4oaJN4QO)X@8?1!x!snn!4f;^iv$OCs*h1<78
z@ygEybCR6{yibq>8%u1PAlVm*HSgFSjbya4o^0!#X?n92I-$9onpIqWtA{!}9tZ+u
zu$JNJFZ;Lr4p^Bf@faKSPo9cYao8E2i?v63TqQ-29AtQ!JJXIAZ`TYgMOYX?i}{<+
z?wf^~c|JK=HQpt-HrRRURsLMOg*9$A17WTZZwerl>pA6?p;mc9G&4!`(a33ne^C&k
z79|$UlMpvyQQ2dP@LTlPpy{GL<JV(ck9msXk$ay$-<gUa!+cC&X!(^k%Qx_n^hZ|=
zvuaIX1A=#10aB(CjxcW6fe_m|X^&8T=T{o@tO9i(X$|0GN4mJV7k|*;EZ@{)GDlI?
z8hq#u6;0)-z{h~;&&ffLrXFyJ^XFKe8iB^1;S(i4RQHT1WDxgy=ugq~`qS9NpYsm#
zKpvqh>NszeKo^EF96h|Q^n+Rj(bTpX_1?lq{|s&IpV+N=DVh+O+478Ci%%eBW7c+h
z`Ai+f9THaa&DTaD2vzG~1PbDbKzF+;Wh*RIb-G{R%ItsSFNQTSd+vukc~IcIz2X&}
zdsC0{NFRyn6gut}41JFcO->!?tJ?}MhUJ}g$WO(5|K<Z^UDaJhL6fTly82-;vGGMS
zQt#SSyB3i*7B2C9g3^UN&^R8$*joLcq`rin*eez6e)JlAZq@yLa>No%Ug&un%JhLP
zs4H+rUcz8^qvVwU*w@)LaN;XHa5^;m+_NO(r*Kl&w?YS2R4}wzV^iePG0EAqIkx2<
zIUD;f6K!Jjj^v>r%{LE7XPw85gbVzbx=}jtt1t4bWH%a9{mh<CXyRq$7WE-<XPd*h
z6G*7it>@v9M2lCfpy*yYVR6QiXzao8sG+IDnt$K0l(UgzGoOQTQ82|;=32A#dI8U}
zrdgSPUdnPzofunBtHG7kGvsz7pMFg0m+dPs6wD1KB_b4|A^@-u;sHTodWj88?8D_@
qyFn@{U3Lz$BLNFQ5VyBqw+u$mFZM~Z?H0=HZMnDhF@OL+y69iul)BIW

literal 0
HcmV?d00001

diff --git a/examples/secrets/trustoresandkeystores/kafka.broker.truststore.jks b/examples/secrets/trustoresandkeystores/kafka.broker.truststore.jks
new file mode 100644
index 0000000000000000000000000000000000000000..4b732b8a1ae18343aa6bde7b72e0f4687aaafe48
GIT binary patch
literal 2146
zcmV-o2%YyZf(Tv$0Ru3C2p0wkDuzgg_YDCD0ic2i2n2!%1TcaK05F0F{00dshDe6@
z4FLxRpn?bOFoFl^0s#Opf(POT2`Yw2hW8Bt2LUiC1_~;MNQU<f0So~KFdGCED%yJZ
zH+{}yAB)NUM2E4*gUdA)0s{cUP=JC5sQ=_N1}{CU>L<7jxD%`gbSihs@0Zy5aNDr3
z48C*M(Q{vbn*((>(3#t_CPBU{k7TTH?;||j+tj#gKB-KmyuRfU1D6pwN{ozQx0)}g
z6&q*DY(qE1u5C7XU%ha52bW@5Rmu45@Y}M#9kn${h#fCQ_5@5<)B?*@+vJ3Y$DD5{
zo{hS7;;pP&N$P_k_MV7oSey5<=2*dAgn~^@=N)-NKs`{D?^U|@j>Fz_Y|@9Kx4aUM
zOR|U;Jy<_0aqXGE;gm&n&K;IgiW<8`uLtPFX1{Mhf2DXc>ZW{zGaVhLCdj%PSB>D)
zacw?}Xf36`u`ea|yS7rkcTRZ-4W9=7xJq`Ib?Z)So~;Xgf6!JZ7pW>w_e!3+Hff#!
zy);PD9_Or$eg{i7Qpj5$=vAAxRHNMQCugxB$`hCK5}<Z0udH(YV7m*~&h=^{*YcLP
z5gC<An8f{}Cd0{O^8lcZctA;L(^7Or1Z<K%?&<7d(IZ1Qkh9jA9yrmuORUpK@7!Tg
zmBvgN;>fo)N2CgXRl9-+Ex&a3l?XWaoLDwfjWlgVWYk7#APDw$3O);Bk+^P*+6$a!
zW6X8a9}Ts!OtOCEbzB#_fnDHth>PC^d0yc;03sj8cI8AEnF)DZ=skyTbn9-cmm@jC
z0vv2Q*laS35E&DdRPf!+_Y2%1jA5<Zf`CaT<@F0&W!j=o#oN&%FZX*T!<`a|o*(c(
zDq6FnD3SC_RgMJ(R?o0)_DRmyMbWHSk2lA>*e^;iJ94(xlIqrX0+?V5SGaK-!y%_N
z@X~E{Ihh9Sd}{M9j;!f_We%@`(G#K9IDs<=$*qH|97rdQw_gFU@ui&8D?I1VWH-Dp
zOrPUfnQtqIrbqZ$acFQzW2!FOtFHGqt*X8UTWhx*j@46EBU267mjwnEa`tE|6a~J|
z9)q$nQh)z269=u%sX0S58MD&cgFCrt=6;T7Eo=QLPvRX5B({XG7`~3&w3-twL?U17
z#O(Chb8&MtIBN(*beEWsd0yAeOIkl&*WHB@fbzqT-=z-*+Div~h%W$I6ch>ocA>19
z=IMJ(v+h3Y;$U*v>1@8j&}6p`C|_@`M`6GQb!c@Yu7MCU?$z0nV^m>CWZBu$j9Cl#
zC*so+w5N4*Y{Tawx*}JAe;RxYCgcs8iE<WG8e`WpzX2CK6g~QG$3qkY7To2K*4x)7
zsnJG#31slWaN-4iUnXJ}*OZa#?O_Cfpv}`e5@m~Dj~hPM>F0VRLCuDt9rvK)W+n0Y
za_;Yy+Cs_Xl>%>@rlp<rJw9z^f-84qE~m4wvJmhxXOcshGB-o}_;J%T+R070!f)``
z*S%xh^0BzwK4u-V-m|ERl_;s;ndgLSHkDw-0~ESO!!HjLoMsgA%9AZumC`4Z_zF`3
zMoIvKB7>H2->2r__kSy1)=45Dn@{W1c1wpMut<4WTE)ZGsY$pW3P528rK|d;1j#M&
zd`6@(9wB}BEI9L;__?rO#AEV6%mXDh`RzUe*2@t45he;dHY<7~J{9Oqc??@)v$oSd
zNN2lRVJo<fUG1L{9FS@DQc(5G{_#ur*U#-WfYrZBm~UHAVnI4$MabAkOF~yNpotES
zaX`1z8QT@HpUjtGJl2=jD376%xkGc_7q)Wb>8K8PDA0dswA8htvOOHHSwR4{{9mvt
znmM$c*?Avx1{O;zA}lywE5scFhU%vz7&*B<MCQJG%FnBW&PQYwq!ys5c)n4F5j0ur
ztQt1U@&k_#_L2MdF{S^}QKC#%Ejgycf!|~m1Z29fYopaSyJ(@5pc48OTgpPO3P>D`
zn3ZXbGK2H{6d-(Bn}DLMyx3$ETQ}ullQ=9xT}3V)ldpyyOF^d7(ux)ql{{Ha?P?Od
zQ<${@tHSjuQi57;CF~IF-?+mWFjh7txVFLM9TG@>oTjKz`#IGPA$^#+nlYy^M3F$W
zM#3NP(*MI!XBug#oz^Wj*0x>o1NkJu@-y>*D6%Xcb2CUh9oA_MZt*7_**vihHOx;w
z|9XIa6`#6$B5f@_WZOHvomI6ir>m4zzwpvm3g8F&HbC)bx_#<D@H7=Bh-{db`DtiZ
zOA_2-51(CbxUdXvI6qntV@s?=7QnXZ&BeOlCRoX$o|`085B~gu(t&ZtC1kY!V4vHW
z!k;mmZ97E}@2jQ!^EI*KF4rl(U*!4ic2l1W-8qd=cKxs>T2YK3;IIlzO$A2MG2o4N
zFzzYilLQ8dt@G~%^bQ6`Q~*Fa+I}b*Mnvm9WnG}=H2!zb=Rki6XR1VXnpAwR22_!!
zM{1LK$}!NDUJY@<%?h$wk$XVjBz0mnp}cbQFi8Eel&%Sh_de&Qj#`2-=QTAW*FxuO
z8}A1)zyr0BAa*#hro#p6wFSf*_f7P_+&K<wVz*NFiF0#jS|+q%*me%(T>-v>s$$IT
zW(6aLuPB*Ki1^1iE8pi-V)u;X9lwQ}<Lw^z)s&eEG@BQY8cVs&>^IBZg8DV-f@JwQ
zz;@sDt=gxQY3^JF$9*gi{{g1)tq+m%)`KZcNiiq_0z<R@IERFn|JR0pfiEx-vEoau
zKui~j%*rAPc`!aOAutIB1uG5%0vZJX1Qd3}!5UC?<2=kZ^B<O9B}0<I9)koF{ZHM4
YRzP&+G#1+Z$}@Co3%?$Y0s{etpn&N6VE_OC

literal 0
HcmV?d00001

diff --git a/examples/secrets/trustoresandkeystores/kafka.client.keystore.jks b/examples/secrets/trustoresandkeystores/kafka.client.keystore.jks
new file mode 100644
index 0000000000000000000000000000000000000000..dc105d9333602abb51eab207c5ddb5e9d46eb7cd
GIT binary patch
literal 4623
zcmY+EWmFW5wuTuPYUu7xL0|wuKxzQ#?nb)1W9XI`gGNFck&tp|5Revzj-f@6?i%2H
z_pW=-S?9-Id#&ev_x|~Sqe=150T|$Dl71{)o_OW>YXSf^peUN885m8{@DKh9j>dHU
zuL#o=7>#N857zx>G_mmh?+PCTKrf00-h-oo*WhPZp#R7JJf{Pa<0kEtPc>~9&xFBe
zvynkip{0;cbPTi~+Q4YwP@_=wq+=P&hg?Baa)gbBFVrdeHWO3P^Gbu)i2Lt@w=iR?
znze$@O^xsJJX;AiAB^kcdNr>0d#%~oE@w8aUlyGtjA&XWT#l~1Ki^x99&&~xZT_Nl
zqkK4$XVkb~u>C&EygOj93l7L*rup46K^4r-60Tbj|MFU;3PE^5YihF~GHSzS8=odu
zZ)$rtSf<{GO@6dgLbkbY61Lj5OskS`3sZ_RsxT)n+Cx;mEJjulx^zX&X86qJC5jFO
z{K|{-!_U_7xhKb?H~n$HNJ=aW&4Q*COPPwBq>#<NavIk^ovi9BaNI*nCJ^)eONk$4
zIRBcg1GZZ1&{paGG8(~gsm;Doc2GzM^SM@4E`xgvs7nyWz^HZo=N_VFU_H$hmRb}<
zY^SIGZqa0F6Ub6$BldSD#vui)s`Ph{8;`VshR<uLwPwEbYvdyQGc@eBz><?2{d2ua
zP9~PKMOKlS77*s?PH3PQ{RfMX^tR^Zrf2u$`UjbXTa|)|e-tIA?l#_Wu8W+dG#K^c
zkL!NW*Ae?FKw+>@(&vL~fYyxU-u@f!d`r$5ST_fV|J+p=tbGHD9oW`hzSTn^#wQv-
z4V{EpdSCHAHBW98uq<b>a_%oLLt!dYe0QXT0j@+ymZ%M>B!bui%P(y;41Sn&n1JJ~
z^1a8E6O}77?Dz~gBPU-b-WB)AFw~BHBEyk#115+ilJ#!C(6n0t9qrjq$L4Ytq;F92
zyr0ypIp<61o}nf>MlI8rmLdyfo*MH@B;vK5cena%GtRU{J;KA>Z1HVV+s=w7s9QNx
z#Er_?OB{jM`W2u*tg^_C_WSj=!jIBs|6W77S0!VPT;HV~c?qH?Vl7y`+fP}y7PGme
z-S!`RyoA5Fk(L~Pu5~TQD=@pI`vTai6qS;Fw7GThh^)kR;Enj~8g6LUFU}3krES`R
z=mknT&JMIQ>no3xEq+gWTsFq%U-NK!1rJDAPb7T%qp&EubSjRYUslfqm3h+?=s)<z
z{#P9yjqU8!BF<Il!q_}O27baU5J4vcoQzy8l9qe3{#Qvn40w_e7y;xRT0-0eE_tC+
zk333FKvQn~y3q#RU>c9PP(2YNZ0kkG*nRxTK{$-3xUEcg!6SwOrUhm8-Ar+@_OX(^
z4o6uG+I{;u+=%QnuD^ol5nmR3N@8=Zl8W4om%J0hPY~A-!)AI=5PA$ECQPQ~;=F3{
zDf1BTz>%p(ICJct#Y8sFRIKO0DP2p$pt21PIgw_5obfb?g-(%=VX*eib(P$`rQ^Ub
z+SLv|Ai)^J6Vo3FbcIfqx7uk-rduuVsDn-CNz3QO*(l9<?;znMwLG+wgzysTz|@Ye
z$8Bjpk$u1}-p!~ncW8;)kg;K#A@y5n#S4efrAyhqF!0rnPzu{U*~P#wd=S-Y?DNFN
zgk5kQ3PVt4`l+W;41_YSyU|m(=_}CWP2QDh*3a_-2)@`P6O}af^USzFx$T3Bnvt?z
zho*|mcm$YW81E`eq`3cR3bBCKuCEeXWeXEqUaTG}rEAzIUEisKv??;#HYx7pY-q_b
z9;+bhx6QVwwYZt+3VpAxHnUM)Y*v=?y|%UCJikG0jUAJ!(|%J9*F8c|7EJeVRpOEh
z5;EeW*`m3jIiuO5d7$}$S^g7J2$BOy^_|`AnFU3KghXEm3W~fG6BGwW<4gX#gpE}c
zjnDTFdWH@_`)9HKCjtDIVX^+luyF=mB;{lr(7`7y5r4NU_wGH9@&7e!WHjFHM!1X}
zrV9FVH8Qg??i$(ZkSpINKTIXqxhruHKi;o%fs$!Ush2n|DS&1+!+@D_I&t~d!vpz1
z?0iAr34dkAH>B+7vkcTtkl(&w$y%9vj>xqyUctCDS#F}C<9i&kJzSR>VcXz@gLbP*
zm!a(Ju2H=&l&6Wr*3b|-By7tI(QB(9Ss0au@h!_)mlL9lOklyt3sY}Us%7sZpVoRV
zRyTN*>*he#Rk4hdO3y)*f-l+6jPn{_U0ZsVHTqcR9JMhR&oT42wrIeCg7cO5_OG$S
zY@E7aBq87qDvFChNM75<S<Y|7W)B!zSU7bb*NqhV&x=T{NMA7Fnjv@msuIAS-$0h2
z6dg@|8uPlks!y+*_!=HM#dXi%)|t?~6aTSq0%Y46Q^E>_^2w8O00RYaCy~0Wy{RL*
z@6zZUdpJO3PT#)18PS?_ww^F~0no#=vAD4m_$?&EQ|qH2-*x^nm~|uM>Hs3$C=o6s
z?BGO{gHu@sJZzUM@7yFM(Iyo95a(mB?Qg)Y+V$xHTwFRjyj8m|v2tl#Op^Bo7nvS@
zHpEw~^_1AiyAtG&I)9mD6~2{4_ECB{D{U8Q$|oVqwv%V9{t04FDMK0bbk4!W#Q%o$
zl^jBmD}Oze92L$*#`BOK3ySrhM6!z-=6@_09V~R%wE?3wWQh1)-tR^6C-uYekWV0@
zhnq1GGK#~?7++rxc<68^!>E<bQY)()%wuOs^3wAJ#;~Wd@dUl<>dh1qMRA-+57gk!
z{&~?86aie+l|-bgooasN0K(u6DCu39HA<?&_wTA}_G)Sgt_IR4>*ja9_m>{lQ(|e(
zaE{^W^tpEN_UNw0KX}~WSXU5gePBCxpX56(;uR`dgAZ`>Wmq-m5;YxAS|y0Yr(y@-
z+=nWBGXm_c>oJ5$xPGU9@UrTj-=jF-V3j#>5xP42u8-((<fTE&p#c-(xLy&wAjQnd
zsHIE&=)e5@@=wPBH-#UmW?4Z+car$tP+zFTQVx#0EC$7hJtQ|)_i!XfLXFJ8Ud4vL
zwZrZ#nUchCS>2PYEx~ELLylC%`sdZyBVSBKa2Gg~G8-lh8?pJlkG!DoBH_ch`{0%z
z`abWH_aj?~+p&`6PMMf6;Me*HLQ=?aiuBe-@)JiAP{ky4eypj7DtW<j))S)Myk8=$
zTB|mkJ|G(vS11VVlg^U1YI@4{Y8c;eQ+=jtCT=oh4Vv+39hIulnSnaqym&5tZWdS+
zCgBi8BY0wZD3$#%u<MxZFtb;>gkY7dkP@s`k|ONX$*3<)T8+ZNsLkvX3bOpwRj%za
zLEMw&VovUp_#Nk!PKG6K-q&GUi_G4%t{pYyZ0~*MT6vtK;kLGewes6M(ji^U7uS@I
z$jN717cV{WBv5!t4b!37vr<R_C-ZRMnj!j6yJ@YyTv`w|!}_f`O^<Y~i|5Z@5B5dK
z5?Fc65)({HKwNv<b4*mI2q3C#)~|inObCKY_)puv8rfnB2;a^nhUc@@{9f@Nz60$o
zABic<=>tYl2(j*#_La^I2g%oB6ZAP31@4e%;ri@#2WBVExyF+xDZUKsyB@sv6j0wI
z4hucel__S8ad9<_efxbEvGZ+URLn5+@Xmnm9cTwd-Pp&yeq*ZMyQ(2WC(RWHv>_4_
z<@E_U4h4y=?J+%=%*A}@##WFYW5K-P8Af5nZl#K)|221(J-;XQ9W(I1Fwyo+6ycZj
z<f9-Y+y(S{+PjmHZkMxFP*{IN1iE!Hl#%JY7tW5&*-VmIRXjo96eCH}3+gl;&-#fJ
zNPf^=I!u?EzYz?RjWTF_*Q6{eHNDK!N|t%+eKGlWst7aOMLO|=d-=JAFrmUjq`;Gm
z24xcjf;%5rY)G<j;?9J-Y*HL?k4xl0HDhOhdROUxDF3aGc2YXVVfZx`g*uc$tm<%7
zgM_xURyV#cw|qZ+=56WUr;qmh)g2MR#Twp0@T9)N&W>(B;%E}n{-+7~@&OA03Hnf3
zVM=X*hzXq3%lj9t^vub^HJsk9Upw}48mY!~`<^*T9}S?ye)e}-3bXg~VV>c{dVXDo
zES2!Izj_sd6^{LxNOCmH(5QoqMh?aJBRZHg*R0u&YxR-;L0_lr@bU%6jmGCSW`{0T
zR#><~?=}dy6m(fm%?(;4V#8d`n0$lEPcOcEQ%vYWRM$iE5eQQM8}QVPVjTu5MKH>d
zbcGx#Z1Jb>)kVdge$<c(B&os=J-g9+2sNpI#slJEQ;GqLd2r=VY^eH(sQ0wzSf`S3
zEM?~PSS2X!O<bkPV`;^M$NAXH$+y&+w%0DA!vZPD({yx0uk0N|q~FvjI`xN{Cbrjm
zk7#jOQ;wib1HA>$eD4kYJ7|i^uTJ{Vx$(+&#^(Ywe-*#>4W_uIWfa`VN|2ySd&tea
ze<d?S#P~;YDnHk7u_=33@O_BU-3Ti)2)eaRn1__{$j9)nXR?v2PK_gqi4lL)9T3sL
zSGxhhf96n+q)x?>)z0^J-58%<%PYA>cuQT*UtEUn1{5#4LzGl%tA-rWLN{efsrt;M
z^5u>qH+Vco!e`k?h!k@|1Io~Kp3z76Y<C8{8+lr7I-fpRO&AbjAWCI;ZiZ+Jt)~=X
z%8&4yI$KF7iHyw_8{XHqQOxP!lHV}VX>Zx*Vy<befAo*ecrPvp2Y?RAgcVQvgKKCR
zw7y3m%gLS8JOx;k-SbVqe9%e!ZG<4^rBAgg?=h1Z6{C22Y2WF?%?`Is{nmX>Y}yWZ
z{!S6K`&nxJRY=Oi<xD!A9OiCZmsi6=e1FYXuI>HZU<Qs2<OWNEt&VQ@&w}6qf!ZV;
z*c_8u_0KyinCgn_AkzY$WVi;{^ez3gl`=o%@j#oqqqHi9<Sl#JaVuiop#VYyn8tOW
zvj0h+jy4p`^*b}Xwsh?8oLsij?xU>h`^>>wV{vuuKa++HiarH=&XLS?4AqQ4!437d
zg4D-lgeO}{t+8w_v6UDnM%*2jG2W`_oe@<6uBEP~?Rq9Dtj@;1rakq^a(r;7`Vb2q
zs$;X5V=`6f)SgJ^v&8WzJ2nrsM6Khlw1YKQXCGgwH!G{x{ISf^5vFK72~|sq(`5`a
zdz4+yE`~d2l!c-c6{~q^Jod85EIDC&x7~P_GmuILap+121+xggrR8L}kDCzZ9_1+z
z6d%anH}j(<#Gp*OZzljDY-g%Yz|pVxrz>Bz{1rd<BkAXAp+mj}f#-5PkX%gQ?;J>8
z$rQCi!D*@d3wTXD%8FYI%bBaOfPkyTvL~-Dws0+T8UTSLT*bLb@zQoNPRoBQ4^=2v
zZUU0RVUDn0`LryIm(y4toLI8*n!~45NhB8JJGcECzO7#BX?F$rpn(NxM&XbqORM%`
zBN<XlC#pP++S7(l8bX?u8|pd*597P~ex3D_0;-DO?fVMV-bq>`nJNjUinrbtq40_R
z6?$x{6KaQBwd&T2cjh3|>=P9Iy!$?)lK47kQ`sX)q6LZQ&Dhb3YrV#18OenQ<WHfo
z2oH(cK=0$e`=Zx?w>#+tF8AjGjyr*Qe&R~5vYuV!BtM9WnBQ;SLzPp)u6p5?=K*Qx
zI~{AU*VbpgkPp8+N@;~S*Tr}*`wJa@!gc-4Q|((>v4UI}j}`d+J30_#0_{_}XAmYb
zzkM{G6u}!d_A<T@oL~E)R63{W!n2_~hc~2+ADaxFkZOr^k3WGLUuaS?#143#@%OM(
zj?|QRyJAc94#%RBH`%wf@qAo52x$Lk{!H;-Ao|s+vAFEtqYzGWi_)fiVXj_5%Zm9&
z;VbuX^2o--6%jgxhKS~w5WlDSC>VIjrPj!yp=s{s8ZaXIL1MIuxc*rPLyMoXCo-VE
z1TBenuzUR`_^^W~{YXF%V?tXQT|1tH=!u`osIl)UN4uN`ePGLzaSbLRtNZ5HEV=cw
z;O`Y~>Omb3?qsjX{C`3)F(|5&WZwyW`}`(Z5ZK0Aw=NJ8;?b)Ul!A@1d`>FOd!}Wh
zMd(W+QS7~<<nBycb~qEcxr2wBcdm{v)}aEH2D5;1u`qcFG0<r-(SYP_4N*F7@s|dy
qb^r`BEv1LT^>38_P<T}rx2Ma3?znDCGl7)twB$EBbPPaz(Z2v4uc@;D

literal 0
HcmV?d00001

diff --git a/examples/secrets/trustoresandkeystores/kafka.client.truststore.jks b/examples/secrets/trustoresandkeystores/kafka.client.truststore.jks
new file mode 100644
index 0000000000000000000000000000000000000000..b003dfddf79fae86d08416f9932306e7335d2767
GIT binary patch
literal 1210
zcmV;r1V#HWf&{h#0Ru3C1aAfjDuzgg_YDCD0ic2eU<85$Trh$JSTKSFR0atuhDe6@
z4FLxRpn?QNFoFa@0s#Opf&@AS2`Yw2hW8Bt2LUiC1_~;MNQU<f0So~KFdGCEolVHf
ze6n?(SKZ+Nl601zOhnks0s{cUP=JC206|-pd%m6Io3ErByXXMh2HeM200q=Jk-K?6
zfdx!-#0K`OAQw21SUBKM45)lH2KYQ8&j0buAWBon3_vX5E~6=z61*4nN(zJ-e-SND
zQ;29Eq*j~X^mMs}d|1*%MyS8wGsNdN^zl4D3>0-NF+WS?(Rj#?w+%vvS>u|Qk<>9t
zX?jfK{v63(6B7d~p$%+HO6aDZWXjf$c-~9X*5SL0qVE78`lTz8#$+BCj)3&T1%zh(
z?xv@ULsy-k!8~d~obH?l;N|*}s|Y4wq;$pt7H-b9gD|P7mf!L#^ubtWf;sjP$%e*G
z8*ux6G!?FH)A0BHgvfwrBA3)_MMCb)^@pO_c_$gF#Pd>Cx<Vvzh_+(XCcm!nl2*};
z8ToVF4UrYKrvcjs4k5JtQIigi-eeu8=LjFD&sN4Ud@c5u)$hmSG_=jaXq_yx{lCFD
z<&U^chO~L4Htyz@K2NL^rB4iw=(}<0Oh)yfZf#cw001Z5qD{;3p`AkFH@<qvKduh7
zH@O*(>qrz|Cc-`%Zx`rX#TF(@^Uh)h%P2A^??NB-ZHG}LIxkly5qw{0P<@EYqI2BE
znh+w9+bbB3E56Cf%TciYvJ**RI&j1{wX72<Hgt>8U9d^3#QDr?Aa-~d($Dp~kIyc7
zYG8GpOQ1rQ9PA!UG*x1T91Q_@2o8MXI%y7OSkQTScQCJ>^dg0t_YSJGhnc=7S-?pV
z{h{+teO?Vu!Olt}Zh63li7VV_*YOZ436W8ai<Z<>ZqW+bSy2v?Zj)2I_iy3+ACck&
z$A1BiChN+Gk|ldKEp0me>HCoYQ;LS<?=Y6+e{PJm#GfXdSR}n_a7+q``}lfF6^m3*
zC%SMF*`lMD!6vFb8YOvS`zPlGyC!7=VFtpJnrb3g5i%NhEaT!&@&4_zi9SnO#RKc2
zs9VwPDAG8am4GvE*v`k5IbHEV+8On4OYX}tOLXRBsqqEk1A1rcG)k*%Zy5@FWuc7l
z=;{BNL=e+r9l%df-Bd?ysm-fRb;Cf>=~FUc8HW@_xn&x<nA)VIs9~HPKSZ~_VC_ub
zuxA@_z@@GB9*5$2Etu{ch_|k>Ji6EhR_uz}#dl3r^{5m#VTTxvxHz;)^+I8#psZ?6
zF<D}EcpuKqW_~@?z}wNwJ`9(m!MDL94_#XEVe_o`d0P9<z_08F9I$xXkgw`xY|i9(
z86G820EALw_+C86Gcj{`wOi_qqb&E#pVjpOSf55WOMADJy&eaOgvcm{tZu0B(8o;o
zD=b{FA`Zw{*y_$#NGx*5{}WZOVkEaTS}dz&Q?d+k-GS!{u)2AEyQ%(jiHbo8DFC9X
zdt{4rJla>1i7-AeAutIB1uG5%0vZJX1QetFASiZw@AD2p4LSbo9r6pVRfz-?OZ%RC
YGrIYd&K_&kRH_0ad|zgk0s{etpr-3LCjbBd

literal 0
HcmV?d00001


From 61cb19a0750a3e44471f54f77390f3e7b2a2516c Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:36:47 +0530
Subject: [PATCH 03/15] Add example for Avro serializer with Kafka producer

---
 examples/kafka-avro-producer/Ballerina.toml |  8 +++
 examples/kafka-avro-producer/main.bal       | 61 +++++++++++++++++++++
 2 files changed, 69 insertions(+)
 create mode 100644 examples/kafka-avro-producer/Ballerina.toml
 create mode 100644 examples/kafka-avro-producer/main.bal

diff --git a/examples/kafka-avro-producer/Ballerina.toml b/examples/kafka-avro-producer/Ballerina.toml
new file mode 100644
index 0000000..7b9c9e1
--- /dev/null
+++ b/examples/kafka-avro-producer/Ballerina.toml
@@ -0,0 +1,8 @@
+[package]
+org = "wso2"
+name = "kafka_avro_serdes_test"
+version = "0.1.0"
+distribution = "2201.8.6"
+
+[build-options]
+observabilityIncluded = true
diff --git a/examples/kafka-avro-producer/main.bal b/examples/kafka-avro-producer/main.bal
new file mode 100644
index 0000000..9e9fc9f
--- /dev/null
+++ b/examples/kafka-avro-producer/main.bal
@@ -0,0 +1,61 @@
+// Copyright (c) 2024, WSO2 LLC. (http://www.wso2.com)
+//
+// WSO2 LLC. licenses this file to you under the Apache License,
+// Version 2.0 (the "License"); you may not use this file except
+// in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+import ballerina/http;
+import ballerinax/confluent.cavroserdes;
+import ballerinax/kafka;
+
+configurable string baseUrl = ?;
+configurable map<anydata> originals = ?;
+configurable map<string> headers = ?;
+
+type Order readonly & record {
+    int orderId;
+    string productName;
+};
+
+service / on new http:Listener(9090) {
+    private final kafka:Producer orderProducer;
+    private final cavroserdes:Client registry;
+
+    function init() returns error? {
+        self.orderProducer = check new (kafka:DEFAULT_URL);
+        self.registry = check new ({
+            baseUrl,
+            originals,
+            headers
+        });
+    }
+
+    resource function post orders(Order newOrder) returns http:Accepted|error {
+        string schema = string `
+            {
+                "namespace": "example.avro",
+                "type": "record",
+                "name": "Order",
+                "fields": [
+                    {"name": "orderId", "type": "int"},
+                    {"name": "productName", "type": "string"}
+                ]
+            }`;
+        byte[] byteValue = check self.registry->serialize(schema, newOrder, "new-subject");
+        check self.orderProducer->send({
+            topic: "test-topic",
+            value: byteValue
+        });
+        return http:ACCEPTED;
+    }
+}

From 8c7a3e3f2add1f05bfa1de38c1b01001a71e0a15 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:37:07 +0530
Subject: [PATCH 04/15] Add example for Avro serializer with Kafka consumer

---
 examples/kafka-avro-consumer/Ballerina.toml |  8 ++++
 examples/kafka-avro-consumer/main.bal       | 50 +++++++++++++++++++++
 2 files changed, 58 insertions(+)
 create mode 100644 examples/kafka-avro-consumer/Ballerina.toml
 create mode 100644 examples/kafka-avro-consumer/main.bal

diff --git a/examples/kafka-avro-consumer/Ballerina.toml b/examples/kafka-avro-consumer/Ballerina.toml
new file mode 100644
index 0000000..7b9c9e1
--- /dev/null
+++ b/examples/kafka-avro-consumer/Ballerina.toml
@@ -0,0 +1,8 @@
+[package]
+org = "wso2"
+name = "kafka_avro_serdes_test"
+version = "0.1.0"
+distribution = "2201.8.6"
+
+[build-options]
+observabilityIncluded = true
diff --git a/examples/kafka-avro-consumer/main.bal b/examples/kafka-avro-consumer/main.bal
new file mode 100644
index 0000000..18d76f1
--- /dev/null
+++ b/examples/kafka-avro-consumer/main.bal
@@ -0,0 +1,50 @@
+// Copyright (c) 2024, WSO2 LLC. (http://www.wso2.com)
+//
+// WSO2 LLC. licenses this file to you under the Apache License,
+// Version 2.0 (the "License"); you may not use this file except
+// in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+import ballerina/io;
+import ballerinax/confluent.cavroserdes;
+import ballerinax/kafka;
+
+type Order readonly & record {
+    int orderId;
+    string productName;
+};
+
+configurable string baseUrl = ?;
+configurable int identityMapCapacity = ?;
+configurable map<anydata> originals = ?;
+configurable map<string> headers = ?;
+
+public function main() returns error? {
+    kafka:Consumer orderConsumer = check new (kafka:DEFAULT_URL, {
+        groupId: "test-topic-id",
+        topics: "test-topic"
+    });
+
+    cavroserdes:Client registry = check new ({
+        baseUrl,
+        identityMapCapacity,
+        originals,
+        headers
+    });
+
+    while true {
+        kafka:AnydataConsumerRecord[] getValues = check orderConsumer->poll(60);
+        byte[] orderData = <byte[]>getValues[0].value;
+        Order getOrder = check registry->deserialize(orderData);
+        io:println("Order : ", getOrder);
+    }
+}

From b7569436c74ce34e23304a386238b35dd224647e Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:38:11 +0530
Subject: [PATCH 05/15] Exclue examples in dev release workflow

---
 .github/workflows/dev-stg-release.yml | 1 +
 1 file changed, 1 insertion(+)

diff --git a/.github/workflows/dev-stg-release.yml b/.github/workflows/dev-stg-release.yml
index 49d6f52..f9d6e5e 100644
--- a/.github/workflows/dev-stg-release.yml
+++ b/.github/workflows/dev-stg-release.yml
@@ -19,3 +19,4 @@ jobs:
     secrets: inherit
     with:
       environment: ${{ github.event.inputs.environment }}
+      additional-publish-flags: "-x :confluent.cavroserdes-examples:build"

From 587625f29d76f9197c013133803289b15d6ac747 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:38:37 +0530
Subject: [PATCH 06/15] Add necessary files to run Kafka server on docker

---
 examples/configs/kafka_server_jaas.conf | 14 ++++++++++++++
 examples/configs/zookeeper_jaas.conf    |  5 +++++
 2 files changed, 19 insertions(+)
 create mode 100644 examples/configs/kafka_server_jaas.conf
 create mode 100644 examples/configs/zookeeper_jaas.conf

diff --git a/examples/configs/kafka_server_jaas.conf b/examples/configs/kafka_server_jaas.conf
new file mode 100644
index 0000000..cb79601
--- /dev/null
+++ b/examples/configs/kafka_server_jaas.conf
@@ -0,0 +1,14 @@
+KafkaServer {
+   org.apache.kafka.common.security.plain.PlainLoginModule required
+   serviceName="test-service"
+   username="admin"
+   password="password"
+   user_admin="password"
+   user_client="client-secret";
+};
+
+Client {
+   org.apache.zookeeper.server.auth.DigestLoginModule required
+   username="admin"
+   password="password";
+};
diff --git a/examples/configs/zookeeper_jaas.conf b/examples/configs/zookeeper_jaas.conf
new file mode 100644
index 0000000..0158eb4
--- /dev/null
+++ b/examples/configs/zookeeper_jaas.conf
@@ -0,0 +1,5 @@
+Server {
+       org.apache.zookeeper.server.auth.DigestLoginModule required
+       user_super="admin-secret"
+       user_admin="password";
+};

From e2e1c621febd82313beeecde549ee9675816cac3 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:39:00 +0530
Subject: [PATCH 07/15] Add README.md to run the examples

---
 ballerina/Dependencies.toml |  4 +-
 examples/README.md          | 76 +++++++++++++++++++++++++++++++++++++
 2 files changed, 78 insertions(+), 2 deletions(-)
 create mode 100644 examples/README.md

diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml
index e844b6f..d74b27f 100644
--- a/ballerina/Dependencies.toml
+++ b/ballerina/Dependencies.toml
@@ -23,7 +23,7 @@ dependencies = [
 [[package]]
 org = "ballerina"
 name = "avro"
-version = "0.1.0"
+version = "0.1.1"
 dependencies = [
 	{org = "ballerina", name = "jballerina.java"}
 ]
@@ -359,7 +359,7 @@ modules = [
 [[package]]
 org = "ballerinax"
 name = "confluent.cregistry"
-version = "0.1.0"
+version = "0.1.1"
 dependencies = [
 	{org = "ballerina", name = "jballerina.java"}
 ]
diff --git a/examples/README.md b/examples/README.md
new file mode 100644
index 0000000..46489bf
--- /dev/null
+++ b/examples/README.md
@@ -0,0 +1,76 @@
+## Examples
+
+The Ballerina Avro Serializer/Deserializer connector for Confluent Schema Registry provides practical examples illustrating usage in various scenarios. Explore these [examples](https://github.com/ballerina-platform/module-ballerinax-confluent.cavroserdes/tree/main/examples).
+
+1. [Kafka Avro producer](https://github.com/ballerina-platform/module-ballerinax-confluent.cavroserdes/tree/main/examples/kafka-avro-producer)
+    This example shows how to publish Avro serialized data to a Kafka topic.
+
+2. [Kafka Avro consumer](https://github.com/ballerina-platform/module-ballerinax-confluent.cavroserdes/tree/main/examples/kafka-avro-consumer)
+    This example shows how to consume data in the correct format from a Kafka topic.
+
+## Prerequisites
+
+Create a `Config.toml` file with the base URL, schema capacity, subject, connection configurations and header values. Here's an example of how your `Config.toml` file should look:
+
+    ```toml
+    baseUrl = <BASE_URL>
+    identityMapCapacity = <SCHEMA_MAP_CAPACITY>
+    subject = <SCHEMA_REGISTRY_TOPIC>
+
+    [originals]
+    "schema.registry.url" = <SCHEMA_REGISTRY_ENDPOINT_URL>
+    "basic.auth.credentials.source" = "USER_INFO"
+    "bootstrap.servers" = "<SERVER>:<PORT>"
+    "schema.registry.basic.auth.user.info" = "<KEY>:<SECRET>"
+
+    [headers]
+    ```
+
+## Running an Example
+
+Execute the following commands to build an example from the source:
+
+* To build an example:
+
+    ```bash
+    bal build
+    ```
+
+* To run an example:
+
+    ```bash
+    bal run
+    ```
+
+
+## Step 01: Start a Kafka Server
+
+Execute the following docker command to start the Kafka server.
+
+```bash
+sudo docker-compose -f docker-compose.yaml up -d
+```
+
+## Step 02: Start the Kafka Producer
+
+Go to the [kafka-avro-producer](https://github.com/ballerina-platform/module-ballerinax-confluent.cavroserdes/tree/main/examples/kafka-avro-producer) directory and start the Ballerina service.
+
+```bash
+bal run
+```
+
+## Step 03: Run the Kafka Consumer
+
+Go to the [kafka-avro-consumer](https://github.com/ballerina-platform/module-ballerinax-confluent.cavroserdes/tree/main/examples/kafka-avro-consumer) directory and execute the following command.
+
+```bash
+bal run
+```
+
+## Step 04: Execute the cURL command
+
+Execute the following curl command in a terminal.
+
+```curl 
+curl http://localhost:9090/orders -H "Content-type:application/json" -d "{\"orderId\": 1, \"productName\": \"sport-shoes\"}"
+```

From 859f663c5c6dc8f39fffe6b2c157dbd707cfd053 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:40:24 +0530
Subject: [PATCH 08/15] Fix license header

---
 examples/build.gradle | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/examples/build.gradle b/examples/build.gradle
index eba5913..1b84a26 100644
--- a/examples/build.gradle
+++ b/examples/build.gradle
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2024, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+ * Copyright (c) 2024, WSO2 Inc. (http://www.wso2.com).
  *
  * WSO2 Inc. licenses this file to you under the Apache License,
  * Version 2.0 (the "License"); you may not use this file except

From 0762ae2433c46d13c83c9f9fb2b11b2c28794d7f Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 20:59:58 +0530
Subject: [PATCH 09/15] Fix building all the directoris in exmaples

---
 examples/build.sh | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/examples/build.sh b/examples/build.sh
index e2659d3..4166236 100755
--- a/examples/build.sh
+++ b/examples/build.sh
@@ -46,6 +46,12 @@ for dir in $(find "$BAL_EXAMPLES_DIR" -type d -maxdepth 1  -mindepth 1); do
   if [[ "$dir" == *build ]]; then
     continue
   fi
+  if [[ "$dir" == *configs ]]; then
+    continue
+  fi
+  if [[ "$dir" == *secrets ]]; then
+    continue
+  fi
   (cd "$dir" && bal "$BAL_CMD" --offline && cd ..); 
 done
 

From e8f091bf68365332949cfb79f27c4af9a3f22315 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 21:00:09 +0530
Subject: [PATCH 10/15] Update README.md in examples

---
 examples/README.md | 15 +--------------
 1 file changed, 1 insertion(+), 14 deletions(-)

diff --git a/examples/README.md b/examples/README.md
index 46489bf..ed603b6 100644
--- a/examples/README.md
+++ b/examples/README.md
@@ -28,20 +28,7 @@ Create a `Config.toml` file with the base URL, schema capacity, subject, connect
 
 ## Running an Example
 
-Execute the following commands to build an example from the source:
-
-* To build an example:
-
-    ```bash
-    bal build
-    ```
-
-* To run an example:
-
-    ```bash
-    bal run
-    ```
-
+Follow these steps to run the examples.
 
 ## Step 01: Start a Kafka Server
 

From e3d2ccda2dc45b0f5ef3c49e09c225f97017764e Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 21:10:03 +0530
Subject: [PATCH 11/15] Update example directory names

---
 examples/kafka-avro-consumer/Ballerina.toml | 2 +-
 examples/kafka-avro-producer/Ballerina.toml | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/examples/kafka-avro-consumer/Ballerina.toml b/examples/kafka-avro-consumer/Ballerina.toml
index 7b9c9e1..61d615f 100644
--- a/examples/kafka-avro-consumer/Ballerina.toml
+++ b/examples/kafka-avro-consumer/Ballerina.toml
@@ -1,6 +1,6 @@
 [package]
 org = "wso2"
-name = "kafka_avro_serdes_test"
+name = "kafka_avro_consumer"
 version = "0.1.0"
 distribution = "2201.8.6"
 
diff --git a/examples/kafka-avro-producer/Ballerina.toml b/examples/kafka-avro-producer/Ballerina.toml
index 7b9c9e1..78ab3ba 100644
--- a/examples/kafka-avro-producer/Ballerina.toml
+++ b/examples/kafka-avro-producer/Ballerina.toml
@@ -1,6 +1,6 @@
 [package]
 org = "wso2"
-name = "kafka_avro_serdes_test"
+name = "kafka_avro_producer"
 version = "0.1.0"
 distribution = "2201.8.6"
 

From 9a01503a90d061de67d47ad344ab743383f958b2 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 21:12:22 +0530
Subject: [PATCH 12/15] Fix not importing kafka module to build examples

---
 examples/build.sh | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/examples/build.sh b/examples/build.sh
index 4166236..121920f 100755
--- a/examples/build.sh
+++ b/examples/build.sh
@@ -52,7 +52,7 @@ for dir in $(find "$BAL_EXAMPLES_DIR" -type d -maxdepth 1  -mindepth 1); do
   if [[ "$dir" == *secrets ]]; then
     continue
   fi
-  (cd "$dir" && bal "$BAL_CMD" --offline && cd ..); 
+  (cd "$dir" && bal "$BAL_CMD" && cd ..); 
 done
 
 # Remove generated JAR files

From ed4d366d1492df0865f83756d20b2d42d9559a6c Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 21:21:17 +0530
Subject: [PATCH 13/15] Add symlinks to example directories

---
 examples/README.md                            |  2 +-
 .../kafka-avro-consumer/.github/README.md     |  1 +
 .../kafka-avro-consumer.md                    | 31 +++++++++++++++++++
 .../kafka-avro-producer/.github/README.md     |  1 +
 .../kafka-avro-producer.md                    | 31 +++++++++++++++++++
 5 files changed, 65 insertions(+), 1 deletion(-)
 create mode 120000 examples/kafka-avro-consumer/.github/README.md
 create mode 100644 examples/kafka-avro-consumer/kafka-avro-consumer.md
 create mode 120000 examples/kafka-avro-producer/.github/README.md
 create mode 100644 examples/kafka-avro-producer/kafka-avro-producer.md

diff --git a/examples/README.md b/examples/README.md
index ed603b6..8900398 100644
--- a/examples/README.md
+++ b/examples/README.md
@@ -6,7 +6,7 @@ The Ballerina Avro Serializer/Deserializer connector for Confluent Schema Regist
     This example shows how to publish Avro serialized data to a Kafka topic.
 
 2. [Kafka Avro consumer](https://github.com/ballerina-platform/module-ballerinax-confluent.cavroserdes/tree/main/examples/kafka-avro-consumer)
-    This example shows how to consume data in the correct format from a Kafka topic.
+    This guide demonstrates how to consume data in the correct format according to Avro schema from a Kafka topic.
 
 ## Prerequisites
 
diff --git a/examples/kafka-avro-consumer/.github/README.md b/examples/kafka-avro-consumer/.github/README.md
new file mode 120000
index 0000000..254e554
--- /dev/null
+++ b/examples/kafka-avro-consumer/.github/README.md
@@ -0,0 +1 @@
+../kafka-avro-consumer.md
\ No newline at end of file
diff --git a/examples/kafka-avro-consumer/kafka-avro-consumer.md b/examples/kafka-avro-consumer/kafka-avro-consumer.md
new file mode 100644
index 0000000..b7b2ca8
--- /dev/null
+++ b/examples/kafka-avro-consumer/kafka-avro-consumer.md
@@ -0,0 +1,31 @@
+# Consume Avro Serialized Data from a Kafka Topic
+
+## Introduction
+
+This guide demonstrates how to consume data in the correct format according to Avro schema from a Kafka topic.
+
+### Configuration
+
+Configure the followings in Config.toml in the example directory.
+
+```toml
+baseUrl = <BASE_URL>
+identityMapCapacity = <SCHEMA_MAP_CAPACITY>
+subject = <SCHEMA_REGISTRY_TOPIC>
+
+[originals]
+"schema.registry.url" = <SCHEMA_REGISTRY_ENDPOINT_URL>
+"basic.auth.credentials.source" = "USER_INFO"
+"bootstrap.servers" = "<SERVER>:<PORT>"
+"schema.registry.basic.auth.user.info" = "<KEY>:<SECRET>"
+
+[headers]
+```
+
+## Run the example
+
+Execute the following command to run the example.
+
+```ballerina
+bal run
+```
diff --git a/examples/kafka-avro-producer/.github/README.md b/examples/kafka-avro-producer/.github/README.md
new file mode 120000
index 0000000..2b1897f
--- /dev/null
+++ b/examples/kafka-avro-producer/.github/README.md
@@ -0,0 +1 @@
+../kafka-avro-producer.md
\ No newline at end of file
diff --git a/examples/kafka-avro-producer/kafka-avro-producer.md b/examples/kafka-avro-producer/kafka-avro-producer.md
new file mode 100644
index 0000000..01f1fd4
--- /dev/null
+++ b/examples/kafka-avro-producer/kafka-avro-producer.md
@@ -0,0 +1,31 @@
+# Publish Avro Serialized Data to a Kafka Topic
+
+## Introduction
+
+This guide demonstrates how to publish Avro serialized data to a Kafka topic.
+
+### Configuration
+
+Configure the followings in Config.toml in the example directory.
+
+```toml
+baseUrl = <BASE_URL>
+identityMapCapacity = <SCHEMA_MAP_CAPACITY>
+subject = <SCHEMA_REGISTRY_TOPIC>
+
+[originals]
+"schema.registry.url" = <SCHEMA_REGISTRY_ENDPOINT_URL>
+"basic.auth.credentials.source" = "USER_INFO"
+"bootstrap.servers" = "<SERVER>:<PORT>"
+"schema.registry.basic.auth.user.info" = "<KEY>:<SECRET>"
+
+[headers]
+```
+
+## Run the example
+
+Execute the following command to run the example.
+
+```ballerina
+bal run
+```

From 0d3672740c11bbb3fc1b7305edba8ede0cf56a12 Mon Sep 17 00:00:00 2001
From: Nuvindu <nuvidu.18@cse.mrt.ac.lk>
Date: Wed, 10 Apr 2024 21:26:49 +0530
Subject: [PATCH 14/15] Update config values in description

---
 examples/README.md                                  | 6 +++---
 examples/kafka-avro-consumer/kafka-avro-consumer.md | 8 ++++----
 examples/kafka-avro-producer/kafka-avro-producer.md | 8 ++++----
 3 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/examples/README.md b/examples/README.md
index 8900398..f0bd8e6 100644
--- a/examples/README.md
+++ b/examples/README.md
@@ -13,12 +13,12 @@ The Ballerina Avro Serializer/Deserializer connector for Confluent Schema Regist
 Create a `Config.toml` file with the base URL, schema capacity, subject, connection configurations and header values. Here's an example of how your `Config.toml` file should look:
 
     ```toml
-    baseUrl = <BASE_URL>
+    baseUrl = "<BASE_URL>"
     identityMapCapacity = <SCHEMA_MAP_CAPACITY>
-    subject = <SCHEMA_REGISTRY_TOPIC>
+    subject = "<SCHEMA_REGISTRY_TOPIC>"
 
     [originals]
-    "schema.registry.url" = <SCHEMA_REGISTRY_ENDPOINT_URL>
+    "schema.registry.url" = "<SCHEMA_REGISTRY_ENDPOINT_URL>"
     "basic.auth.credentials.source" = "USER_INFO"
     "bootstrap.servers" = "<SERVER>:<PORT>"
     "schema.registry.basic.auth.user.info" = "<KEY>:<SECRET>"
diff --git a/examples/kafka-avro-consumer/kafka-avro-consumer.md b/examples/kafka-avro-consumer/kafka-avro-consumer.md
index b7b2ca8..a0df137 100644
--- a/examples/kafka-avro-consumer/kafka-avro-consumer.md
+++ b/examples/kafka-avro-consumer/kafka-avro-consumer.md
@@ -6,15 +6,15 @@ This guide demonstrates how to consume data in the correct format according to A
 
 ### Configuration
 
-Configure the followings in Config.toml in the example directory.
+Configure the followings in `Config.toml` in the directory.
 
 ```toml
-baseUrl = <BASE_URL>
+baseUrl = "<BASE_URL>"
 identityMapCapacity = <SCHEMA_MAP_CAPACITY>
-subject = <SCHEMA_REGISTRY_TOPIC>
+subject = "<SCHEMA_REGISTRY_TOPIC>"
 
 [originals]
-"schema.registry.url" = <SCHEMA_REGISTRY_ENDPOINT_URL>
+"schema.registry.url" = "<SCHEMA_REGISTRY_ENDPOINT_URL>"
 "basic.auth.credentials.source" = "USER_INFO"
 "bootstrap.servers" = "<SERVER>:<PORT>"
 "schema.registry.basic.auth.user.info" = "<KEY>:<SECRET>"
diff --git a/examples/kafka-avro-producer/kafka-avro-producer.md b/examples/kafka-avro-producer/kafka-avro-producer.md
index 01f1fd4..e5b20e5 100644
--- a/examples/kafka-avro-producer/kafka-avro-producer.md
+++ b/examples/kafka-avro-producer/kafka-avro-producer.md
@@ -6,15 +6,15 @@ This guide demonstrates how to publish Avro serialized data to a Kafka topic.
 
 ### Configuration
 
-Configure the followings in Config.toml in the example directory.
+Configure the followings in `Config.toml` in the directory.
 
 ```toml
-baseUrl = <BASE_URL>
+baseUrl = "<BASE_URL>"
 identityMapCapacity = <SCHEMA_MAP_CAPACITY>
-subject = <SCHEMA_REGISTRY_TOPIC>
+subject = "<SCHEMA_REGISTRY_TOPIC>"
 
 [originals]
-"schema.registry.url" = <SCHEMA_REGISTRY_ENDPOINT_URL>
+"schema.registry.url" = "<SCHEMA_REGISTRY_ENDPOINT_URL>"
 "basic.auth.credentials.source" = "USER_INFO"
 "bootstrap.servers" = "<SERVER>:<PORT>"
 "schema.registry.basic.auth.user.info" = "<KEY>:<SECRET>"

From ac798816a43928a12c599a9c24f672def5b82e81 Mon Sep 17 00:00:00 2001
From: Nuvindu Nirmana <63797478+Nuvindu@users.noreply.github.com>
Date: Wed, 10 Apr 2024 21:27:24 +0530
Subject: [PATCH 15/15] Remove the `sudo` command

Co-authored-by: Thisaru Guruge <thisaru@wso2.com>
---
 examples/README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/examples/README.md b/examples/README.md
index f0bd8e6..2355afb 100644
--- a/examples/README.md
+++ b/examples/README.md
@@ -35,7 +35,7 @@ Follow these steps to run the examples.
 Execute the following docker command to start the Kafka server.
 
 ```bash
-sudo docker-compose -f docker-compose.yaml up -d
+docker-compose -f docker-compose.yaml up -d
 ```
 
 ## Step 02: Start the Kafka Producer