saranyaeu2987 commented on issue #251:
URL: 
https://github.com/apache/camel-kafka-connector/issues/251#issuecomment-635980019


   Got it. 
   I wanted to add variable date in camel.sink.url. is there a way to add it. 
   without variable part, the file in S3 is getting overwritten. 
   
   Here is my yaml file for your reference 
   ```
   apiVersion: kafka.strimzi.io/v1alpha1
   kind: KafkaConnector
   metadata:
     name: s3-sink-connector
     labels:
       strimzi.io/cluster: my-connect-cluster
   spec:
     class: org.apache.camel.kafkaconnector.CamelSinkConnector
     tasksMax: 1
     config:
       key.converter: org.apache.kafka.connect.storage.StringConverter
       value.converter: org.apache.kafka.connect.storage.StringConverter
       topics: my-replicated-topic
       camel.sink.url: 
aws-s3://selumalai-kafka-s3?keyName=${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}
       camel.sink.maxPollDuration: 10000
       camel.component.aws-s3.configuration.autocloseBody: false
       camel.component.aws-s3.accessKey: 
${file:/opt/kafka/external-configuration/aws-credentials/aws-credentials.properties:aws_access_key_id}
       camel.component.aws-s3.secretKey: 
${file:/opt/kafka/external-configuration/aws-credentials/aws-credentials.properties:aws_secret_access_key}
       camel.component.aws-s3.region: US_WEST_2
   ```


----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to