jonaswagner commented on issue #1107: URL: https://github.com/apache/camel-kafka-connector/issues/1107#issuecomment-801717479
You are right, I was blindly reading the documentation (see https://camel.apache.org/camel-kafka-connector/latest/connectors/camel-aws2-s3-kafka-source-connector.html), which says that the connector supports the S3 Converter out of the box. I was also confused by the sample configuration of the aws-s3-kafka-source-connector (not aws2) example, which contains a StringConverter and the S3ObjectConverter (see https://camel.apache.org/camel-kafka-connector/latest/connectors/camel-aws-s3-kafka-source-connector.html#_examples) Now that I have everything working I share my final configuration, which is: spec: class: org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector tasksMax: 1 config: camel.source.path.bucketNameOrArn: my-bucket-name camel.source.endpoint.autoCreateBucket: false camel.source.endpoint.region: my-region camel.source.endpoint.deleteAfterRead: true camel.source.endpoint.fileName: devl/shared/targetfile.csv camel.source.endpoint.accessKey: "" camel.source.endpoint.secretKey: "" camel.source.maxPollDuration: 10000 camel.source.endpoint.delay: 10000 camel.source.endpoint.autocloseBody: false topics: test-name.targetfile.source.s3 Thank you very much for helping me :) Should I close this issue now? ---------------------------------------------------------------- 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
