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

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

commit 6d3e983864f144f8b5fe65ed72eb16d447bf67db
Author: Andrea Cosentino <[email protected]>
AuthorDate: Thu May 25 14:36:24 2023 +0200

    Bean: Use properties instead of property with key and value - Kafka SSL 
Source
    
    Signed-off-by: Andrea Cosentino <[email protected]>
---
 kamelets/kafka-ssl-source.kamelet.yaml | 47 ++++++++++++----------------------
 1 file changed, 16 insertions(+), 31 deletions(-)

diff --git a/kamelets/kafka-ssl-source.kamelet.yaml 
b/kamelets/kafka-ssl-source.kamelet.yaml
index 0dfadc26..8d9e5172 100644
--- a/kamelets/kafka-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-ssl-source.kamelet.yaml
@@ -155,37 +155,22 @@ spec:
       - name: kafka-ssl-source-local
         type: '#class:org.apache.camel.component.kafka.KafkaComponent'
       - name: kafka-ssl-sink-configuration-local
-        property:
-          - key: brokers
-            value: '{{bootstrapServers}}'
-          - key: securityProtocol
-            value: '{{securityProtocol}}'
-          - key: sslKeystoreLocation
-            value: '{{?sslKeystoreLocation}}'
-          - key: sslKeyPassword
-            value: '{{sslKeyPassword}}'
-          - key: sslKeystorePassword
-            value: '{{?sslKeystorePassword}}'
-          - key: sslTruststoreLocation
-            value: '{{sslTruststoreLocation}}'
-          - key: sslProtocol
-            value: '{{sslProtocol}}'
-          - key: sslEnabledProtocols
-            value: '{{sslEnabledProtocols}}'
-          - key: saslMechanism
-            value: '{{saslMechanism}}'
-          - key: groupId
-            value: '{{?consumerGroup}}'
-          - key: autoOffsetReset
-            value: '{{autoOffsetReset}}'
-          - key: pollOnError
-            value: '{{pollOnError}}'
-          - key: allowManualCommit
-            value: '{{allowManualCommit}}'
-          - key: autoCommitEnable
-            value: '{{autoCommitEnable}}'
-          - key: saslJaasConfig
-            value: '{{?saslJaasConfig}}'
+        properties:
+          brokers: '{{bootstrapServers}}'
+          securityProtocol: '{{securityProtocol}}'
+          sslKeystoreLocation: '{{sslKeystoreLocation}}'
+          sslKeyPassword: '{{sslKeyPassword}}'
+          sslKeystorePassword: '{{sslKeystorePassword}}'
+          sslTruststoreLocation: '{{sslTruststoreLocation}}'
+          sslProtocol: '{{sslProtocol}}'
+          sslEnabledProtocols: '{{sslEnabledProtocols}}'
+          saslMechanism: '{{saslMechanism}}' 
+          groupId: '{{?consumerGroup}}'
+          autoOffsetReset: '{{autoOffsetReset}}'
+          pollOnError: '{{pollOnError}}'
+          allowManualCommit: '{{allowManualCommit}}'
+          autoCommitEnable: '{{autoCommitEnable}}'
+          saslJaasConfig: '{{?saslJaasConfig}}'
         type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
       - name: kafkaHeaderDeserializer
         type: 
"#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer"

Reply via email to