AishD3 commented on issue #1604:
URL:
https://github.com/apache/camel-kafka-connector/issues/1604#issuecomment-1987924217
@Oscerd how about fileName - I tried to pass exchangeID is Kafka Header ,
but its not able to set the file name in Datalake on what I give.
Kafka Header
{
"exchangeId": "adlstest_1000"
}
Connector Configs :
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:
328ea5df-d095-4c9f-ba69-79c468792db9
camel.kamelet.azure-storage-datalake-sink.clientSecret: wvvvvvvvvrlanA
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-vvvvvvvvk-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-vvvvvvvvvdigital.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 : "messages-${date:now:yyyyMMdd}.txt"
--
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]
