| apiVersion: kafka.strimzi.io/v1alpha1 |
| kind: KafkaConnector |
| metadata: |
| name: s3-sink-connector |
| namespace: myproject |
| labels: |
| strimzi.io/cluster: my-connect-cluster |
| spec: |
| class: org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SinkConnector |
| tasksMax: 1 |
| config: |
| key.converter: org.apache.kafka.connect.storage.StringConverter |
| value.converter: org.apache.kafka.connect.storage.StringConverter |
| topics: s3-topic |
| camel.sink.path.bucketNameOrArn: camel-kafka-connector |
| camel.sink.endpoint.keyName: ${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId} |
| camel.beans.aggregate: #class:org.apache.camel.kafkaconnector.aggregator.StringAggregator |
| camel.aggregation.size: 10 |
| camel.aggregation.timeout: 5000 |
| camel.component.aws2-s3.accessKey: ${file:/opt/kafka/external-configuration/aws-credentials/aws2-s3-cred.properties:accessKey} |
| camel.component.aws2-s3.secretKey: ${file:/opt/kafka/external-configuration/aws-credentials/aws2-s3-cred.properties:secretKey} |
| camel.component.aws2-s3.region: ${file:/opt/kafka/external-configuration/aws-credentials/aws2-s3-cred.properties:region} |
