S3 source connector writing duplicate messages for one S3 payload.

[dezka]

Version 3.20.3 of the connector, Kafka Connect 2.8, Java 11, Kafka 2.8.

I am sure this is a misconfiguration on my part, though I've looked through docs and I can't really find where I'm going wrong here.

{
  "connector.class": "org.apache.camel.kafkaconnector.awss3source.CamelAwss3sourceSourceConnector",
  "camel.kamelet.aws-s3-source.deleteAfterRead": "true",
  "camel.kamelet.aws-s3-source.bucketNameOrArn": "my-bucket",
  "topics": "mytopic",
  "tasks.max": "1",
  "name": "s3-source-test",
  "value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
  "camel.kamelet.aws-s3-source.useDefaultCredentialsProvider": "true",
  "camel.kamelet.aws-s3-source.region": "us-east-1"
}

I upload one file containing the following json:

{"type":"s3","settings":{"bucket":"test123","base_path":"backups"}}

When it's processed, I see two messages show up in my topic with this same payload.

[dezka]

Closing this due to realizing it's an issue with the publisher and not this plugin.