What is the kafka version used?

from camel-kafka-connector-examples.

Kafka Version | 2.11-2.4.0

from camel-kafka-connector-examples.

and the camel-kafka-connector version?

from camel-kafka-connector-examples.

camel-aws-s3-source-kafka-connector-3..19.0-SNAPSHOT.jar

from camel-kafka-connector-examples.

same error when I try Camel Azure storage blob Source Connector

from camel-kafka-connector-examples.

We never seen something like this before. You need also to take into account this repository is not up-to-date with the latest release of ckc.

from camel-kafka-connector-examples.

ok, thanks for letting us know. May I know when can we expect the latest release? so that we can try again.

from camel-kafka-connector-examples.

There is no ETA for 3.19.0 release. First we need to release camel-kamelets 0.10.0 and then update on the ckc side.

from camel-kafka-connector-examples.

Can you please also show the configuration of the connector?

from camel-kafka-connector-examples.

name=CamelAws-s3-sourceSourceConnector
connector.class=org.apache.camel.kafkaconnector.awss3source.CamelAwss3sourceSourceConnector
tasks.max=1

use the kafka converters that better suit your needs, these are just defaults:

key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter

comma separated topics to send messages into

topics=DemoPOC

mandatory properties (for a complete properties list see the connector documentation):

The S3 Bucket name or Amazon Resource Name (ARN).

camel.kamelet.aws-s3-source.bucketNameOrArn=arn:aws:s3:::xxxxxxxxxxxxxxxxxxxxx

The AWS region to access.

camel.kamelet.aws-s3-source.region=ap-southeast-1
camel.source.endpoint.autocloseBody=false
camel.component.aws-s3.configuration.access-key=
camel.component.aws-s3.configuration.secret-key=

from camel-kafka-connector-examples.

Please use the correct parameters: https://camel.apache.org/camel-kafka-connector/3.18.x/reference/connectors/camel-aws-s3-source-kafka-source-connector.html

You're mixing up configuration from 0.11.x and 3.x. If you are using a ckc version > 1.0 then you should use the camel-kamelets options, like reported in the documentation for the connector.

from camel-kafka-connector-examples.