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 862ebbe3b90ef2a1333ca43b4fa2b1f30eb37779 Author: Andrea Cosentino <[email protected]> AuthorDate: Thu May 25 14:40:07 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 | 5 +-- .../kamelets/kafka-ssl-source.kamelet.yaml | 51 ++++++++-------------- 2 files changed, 20 insertions(+), 36 deletions(-) diff --git a/kamelets/kafka-ssl-source.kamelet.yaml b/kamelets/kafka-ssl-source.kamelet.yaml index f486700d..e15b59c9 100644 --- a/kamelets/kafka-ssl-source.kamelet.yaml +++ b/kamelets/kafka-ssl-source.kamelet.yaml @@ -174,9 +174,8 @@ spec: type: '#class:org.apache.camel.component.kafka.KafkaConfiguration' - name: kafkaHeaderDeserializer type: "#class:org.apache.camel.kamelets.utils.serialization.kafka.KafkaHeaderDeserializer" - property: - - key: enabled - value: '{{deserializeHeaders}}' + properties: + enabled: '{{deserializeHeaders}}' from: uri: "{{kafka-ssl-source-local}}:{{topic}}" parameters: diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml index 0dfadc26..f486700d 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-ssl-source.kamelet.yaml @@ -154,38 +154,23 @@ spec: beans: - 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}}' + - name: kafka-ssl-source-configuration-local + 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" @@ -195,7 +180,7 @@ spec: from: uri: "{{kafka-ssl-source-local}}:{{topic}}" parameters: - configuration: '#bean:{{kafka-ssl-sink-configuration-local}}' + configuration: '#bean:{{kafka-ssl-source-configuration-local}}' steps: - process: ref: "{{kafkaHeaderDeserializer}}"
