java.lang.IllegalArgumentException: Can't find fileNamingStrategy in config" for AWS S3 connector

Apache Kafka Connectors
1

I’m having trouble getting the S3 Sink to work with AWS MSK Connect.

The issue that I’m having is that it throws an error that says “java.lang.IllegalArgumentException: Can’t find fileNamingStrategy in config”.

I’ve tried running in MSK Connect and our own Connect cluster and I get the same result.

connector.class=io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnector
key.converter.schemas.enable=false
connect.s3.kcql=INSERT INTO hyphen-xxxx-msk-backup:test11 SELECT * FROM aws.east.xxxx.xxxx.fct.channel.import.queue.0 STOREAS `JSON` WITH_FLUSH_COUNT = 5
aws.region=us-east-1
tasks.max=1
topics=aws.east.xxxxx.smilecdr.fct.channel.import.queue.0
schema.enable=false
value.converter=org.apache.kafka.connect.json.JsonConverter
errors.log.enable=true
key.converter=org.apache.kafka.connect.json.JsonConverter
2

You should try to escape the string of the source topic in the KCQL statement by encapsulating it with backticks. Like this:

connect.s3.kcql=INSERT INTO hyphen-xxxxx-msk-backup:test11 SELECT * FROM `aws.east.xxxx.xxxx.fct.channel.import.queue.0` STOREAS `JSON` WITH_FLUSH_COUNT = 5