This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit b76731800b89547bf78fe3da927b802d24a5b142
Author: Andrea Cosentino <[email protected]>
AuthorDate: Thu Oct 19 13:02:38 2023 +0200

    Create a Specialized Kamelet starting from Kafka Source using Azure Schema 
Registry - Added Kamelet
    
    Signed-off-by: Andrea Cosentino <[email protected]>
---
 kamelets/kafka-azure-schema-registry-source.kamelet.yaml                | 2 +-
 .../resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml 
b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 52c44885..568fdb7e 100644
--- a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -154,7 +154,7 @@ spec:
         brokers: "{{bootstrapServers}}"
         securityProtocol: "{{securityProtocol}}"
         saslMechanism: "{{saslMechanism}}"
-        saslJaasConfig: 
'org.apache.kafka.common.security.plain.PlainLoginModule required 
username="$ConnectionString" password={{connectionstring}};'
+        saslJaasConfig: 
'org.apache.kafka.common.security.plain.PlainLoginModule required 
username="$ConnectionString" password={{password}};'
         autoCommitEnable: "{{autoCommitEnable}}"
         allowManualCommit: "{{allowManualCommit}}"
         pollOnError: "{{pollOnError}}"
diff --git 
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
 
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 52c44885..568fdb7e 100644
--- 
a/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++ 
b/library/camel-kamelets/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -154,7 +154,7 @@ spec:
         brokers: "{{bootstrapServers}}"
         securityProtocol: "{{securityProtocol}}"
         saslMechanism: "{{saslMechanism}}"
-        saslJaasConfig: 
'org.apache.kafka.common.security.plain.PlainLoginModule required 
username="$ConnectionString" password={{connectionstring}};'
+        saslJaasConfig: 
'org.apache.kafka.common.security.plain.PlainLoginModule required 
username="$ConnectionString" password={{password}};'
         autoCommitEnable: "{{autoCommitEnable}}"
         allowManualCommit: "{{allowManualCommit}}"
         pollOnError: "{{pollOnError}}"

Reply via email to