This is an automated email from the ASF dual-hosted git repository.
oscerd pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new 446bebc81 Fix #2972: quote the password in the Azure schema-registry
Kamelets' JAAS config (#2975)
446bebc81 is described below
commit 446bebc81f3919de7262d04b83e9fcad22cc010a
Author: Andrea Cosentino <[email protected]>
AuthorDate: Mon Aug 24 18:41:48 2026 +0200
Fix #2972: quote the password in the Azure schema-registry Kamelets' JAAS
config (#2975)
The three kafka-azure-schema-registry Kamelets built their sasl.jaas.config
with the password unquoted:
PlainLoginModule required username="$ConnectionString"
password={{password}};
username="$ConnectionString" means the password is an Event Hubs connection
string, which always contains semicolons. JAAS ends an unquoted value at the
first semicolon, so Kafka's own parser rejects the result outright:
IllegalArgumentException: Value not specified for key 'null' in JAAS
config
Quoting the value makes it parse and preserves the connection string intact.
Co-authored-by: Claude Opus 5 (1M context) <[email protected]>
---
kamelets/kafka-azure-schema-registry-sink.kamelet.yaml | 2 +-
kamelets/kafka-azure-schema-registry-source.kamelet.yaml | 2 +-
kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
b/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
index 79fcebfd8..5d775d210 100644
--- a/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
@@ -122,7 +122,7 @@ spec:
brokers: "{{bootstrapServers}}"
securityProtocol: "{{securityProtocol}}"
saslMechanism: "{{saslMechanism}}"
- saslJaasConfig:
'org.apache.kafka.common.security.plain.PlainLoginModule required
username="$ConnectionString" password={{password}};'
+ saslJaasConfig:
'org.apache.kafka.common.security.plain.PlainLoginModule required
username="$ConnectionString" password="{{password}}";'
valueSerializer: "{{valueSerializer}}"
additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
additionalProperties.schema.group: avro
diff --git a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
index 5fbc6f1d8..8e8344560 100644
--- a/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -134,7 +134,7 @@ spec:
brokers: "{{bootstrapServers}}"
securityProtocol: "{{securityProtocol}}"
saslMechanism: "{{saslMechanism}}"
- saslJaasConfig:
'org.apache.kafka.common.security.plain.PlainLoginModule required
username="$ConnectionString" password={{password}};'
+ saslJaasConfig:
'org.apache.kafka.common.security.plain.PlainLoginModule required
username="$ConnectionString" password="{{password}}";'
autoCommitEnable: "{{autoCommitEnable}}"
allowManualCommit: "{{allowManualCommit}}"
pollOnError: "{{pollOnError}}"
diff --git a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index 5acfc051c..bee701b12 100644
--- a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-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={{password}};'
+ saslJaasConfig:
'org.apache.kafka.common.security.plain.PlainLoginModule required
username="$ConnectionString" password="{{password}}";'
autoCommitEnable: "{{autoCommitEnable}}"
allowManualCommit: "{{allowManualCommit}}"
pollOnError: "{{pollOnError}}"
