Error "Identity-AuthenticationType" in S3 sink

Apache Kafka Connectors
1

Hello everyone!
I’m trying to use the S3 Sink connector and after several attempts I got it running. The problem is that a few moments after it started, I see this error in the logs:

Illegal character in: Identity-AuthenticationType (io.lenses.streamreactor.connect.cloud.common.sink.writer.Writer:61)

In this case, I have no clue of what the issue might be…
How can I get some help understanding what is causing the issue?

Connector version: (https://github.com/lensesio/stream-reactor/releases/download/7.3.2/kafka-connect-aws-s3-7.3.2.zip
Connector configuration:

connector.class=io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnector
connect.s3.kcql=INSERT INTO aBucket:aPrefix SELECT * FROM `*` STOREAS `AVRO` PROPERTIES('store.envelope'=true,'flush.count'=1)
topics=list,of,topics
tasks.max=5
connect.s3.seek.max.files=20
name=msk-s3-sink
connect.s3.aws.region=us-east-1 value.converter=org.apache.kafka.connect.converters.ByteArrayConverter errors.log.enable=true key.converter=org.apache.kafka.connect.converters.ByteArrayConverter
2

Looks like it is working with these properties:

PROPERTIES('store.envelope.key'=true , 'store.envelope.value'=true, 'store.envelope.metadata'=true, 'store.envelope.headers'=false,'flush.count'=1)
1 Like