AishD3 commented on issue #1604:
URL:
https://github.com/apache/camel-kafka-connector/issues/1604#issuecomment-1987948831
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
name: adls-sink
labels:
strimzi.io/cluster: cdt-connect-shared-emp
spec:
class:
org.apache.camel.kafkaconnector.azurestoragedatalakesink.CamelAzurestoragedatalakesinkSinkConnector
tasksMax: 2
config:
topics:
msk.emp.cdtadlsconnectorsink.topic.internal.any.v1,msk.emp.cdtadlsconnectorsink.topic.internal.any.v2
camel.kamelet.azure-storage-datalake-sink.accountName: retinaconnectorpoc
camel.kamelet.azure-storage-datalake-sink.clientId: 328dddddddddb9
camel.kamelet.azure-storage-datalake-sink.clientSecret:
wro8ddddddddddddodwP.~rlanA
camel.kamelet.azure-storage-datalake-sink.tenantId:
05d75c05-fa1a-42e7-9cf1-eb416c396f2d
camel.kamelet.azure-storage-datalake-sink.fileSystemName: test
value.converter.schema.registry.ssl.key.password:
${env:SSL_TRUSTSTORE_PASSWORD}
value.converter.schema.registry.ssl.keystore.location:
/opt/kafka/external-configuration/sr-certs/keystore.jks
value.converter.schema.registry.ssl.keystore.password:
${env:SSL_TRUSTSTORE_PASSWORD}
value.converter.schema.registry.ssl.truststore.location:
/opt/kafka/external-configuration/sr-certs/truststore.jks
value.converter.schema.registry.ssl.truststore.password:
${env:SSL_TRUSTSTORE_PASSWORD}
value.converter.schema.registry.url:
https://cdt-west-2-shared-emp-kafka-sr.maersk-digital.net
value.converter.schemas.enable: false
key.converter.schema.registry.ssl.key.password:
${env:SSL_TRUSTSTORE_PASSWORD}
key.converter.schema.registry.ssl.keystore.location:
/opt/kafka/external-configuration/sr-certs/keystore.jks
key.converter.schema.registry.ssl.keystore.password:
${env:SSL_TRUSTSTORE_PASSWORD}
key.converter.schema.registry.ssl.truststore.location:
/opt/kafka/external-configuration/sr-certs/truststore.jks
key.converter.schema.registry.ssl.truststore.password:
${env:SSL_TRUSTSTORE_PASSWORD}
key.converter.schema.registry.url:
https://cdt-west-2-shared-emp-kafka-sr.maersk-digital.net
key.converter.schemas.enable: false
key.converter: org.apache.kafka.connect.storage.StringConverter
value.converter: org.apache.kafka.connect.storage.StringConverter
camel.aggregation.size: 5
camel.aggregation.timeout: 50000
camelHeader.camelFileName: "adlstestfileanem_1000"
camel.sink.path.directoryName : "/user/app/folder"
camel.sink.endpoint.charset : "UTF-8"
camel.sink.endpoint.fileName : "${exchangeId}"
camel.sink.endpoint.keyName: "${exchangeId}"
camelHeader.camelAzureStorageDataLakeFileName: "${exchangeId}_adlstest"
Is it like this, I added in last line in connector configs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
