This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 1a65e00 Merge pull request #204 from valdar/flakeyTests
add 3a7cfe1 Bump to Camel 3.2.0
new 9cb3266 Merge pull request #206 from apache/camel-3.2.0
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
connectors/camel-activemq-kafka-connector/pom.xml | 12 +
.../docs/camel-activemq-kafka-sink-connector.adoc | 29 +-
.../camel-activemq-kafka-source-connector.adoc | 25 +-
.../activemq/CamelActivemqSinkConnectorConfig.java | 68 +++--
.../CamelActivemqSourceConnectorConfig.java | 68 +++--
connectors/camel-ahc-kafka-connector/pom.xml | 12 +
connectors/camel-ahc-ws-kafka-connector/pom.xml | 12 +
connectors/camel-ahc-wss-kafka-connector/pom.xml | 12 +
connectors/camel-amqp-kafka-connector/pom.xml | 12 +
.../main/docs/camel-amqp-kafka-sink-connector.adoc | 29 +-
.../docs/camel-amqp-kafka-source-connector.adoc | 25 +-
.../amqp/CamelAmqpSinkConnectorConfig.java | 68 +++--
.../amqp/CamelAmqpSourceConnectorConfig.java | 68 +++--
connectors/camel-apns-kafka-connector/pom.xml | 12 +
.../docs/camel-apns-kafka-source-connector.adoc | 4 +-
.../apns/CamelApnsSourceConnectorConfig.java | 4 +-
connectors/camel-as2-kafka-connector/pom.xml | 12 +
.../docs/camel-as2-kafka-source-connector.adoc | 4 +-
.../as2/CamelAs2SourceConnectorConfig.java | 4 +-
connectors/camel-asterisk-kafka-connector/pom.xml | 12 +
connectors/camel-atmos-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
connectors/camel-atom-kafka-connector/pom.xml | 12 +
.../docs/camel-atom-kafka-source-connector.adoc | 4 +-
.../atom/CamelAtomSourceConnectorConfig.java | 4 +-
.../camel-atomix-map-kafka-connector/pom.xml | 12 +
.../camel-atomix-map-kafka-sink-connector.adoc | 15 +-
.../camel-atomix-map-kafka-source-connector.adoc | 15 +-
.../CamelAtomixmapSinkConnectorConfig.java | 46 +++-
.../CamelAtomixmapSourceConnectorConfig.java | 46 +++-
.../camel-atomix-messaging-kafka-connector/pom.xml | 12 +
...amel-atomix-messaging-kafka-sink-connector.adoc | 16 +-
...el-atomix-messaging-kafka-source-connector.adoc | 16 +-
.../CamelAtomixmessagingSinkConnectorConfig.java | 50 +++-
.../CamelAtomixmessagingSourceConnectorConfig.java | 50 +++-
.../camel-atomix-multimap-kafka-connector/pom.xml | 12 +
...camel-atomix-multimap-kafka-sink-connector.adoc | 15 +-
.../CamelAtomixmultimapSinkConnectorConfig.java | 46 +++-
.../camel-atomix-queue-kafka-connector/pom.xml | 12 +
.../camel-atomix-queue-kafka-sink-connector.adoc | 13 +-
.../camel-atomix-queue-kafka-source-connector.adoc | 13 +-
.../CamelAtomixqueueSinkConnectorConfig.java | 38 ++-
.../CamelAtomixqueueSourceConnectorConfig.java | 38 ++-
.../camel-atomix-set-kafka-connector/pom.xml | 12 +
.../camel-atomix-set-kafka-sink-connector.adoc | 14 +-
.../camel-atomix-set-kafka-source-connector.adoc | 14 +-
.../CamelAtomixsetSinkConnectorConfig.java | 42 ++-
.../CamelAtomixsetSourceConnectorConfig.java | 42 ++-
.../camel-atomix-value-kafka-connector/pom.xml | 12 +
.../camel-atomix-value-kafka-sink-connector.adoc | 14 +-
.../camel-atomix-value-kafka-source-connector.adoc | 14 +-
.../CamelAtomixvalueSinkConnectorConfig.java | 42 ++-
.../CamelAtomixvalueSourceConnectorConfig.java | 42 ++-
connectors/camel-avro-kafka-connector/pom.xml | 12 +
.../main/docs/camel-avro-kafka-sink-connector.adoc | 8 +-
.../docs/camel-avro-kafka-source-connector.adoc | 8 +-
.../avro/CamelAvroSinkConnectorConfig.java | 24 ++
.../avro/CamelAvroSourceConnectorConfig.java | 24 ++
connectors/camel-aws-cw-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-cw-kafka-sink-connector.adoc | 18 +-
.../awscw/CamelAwscwSinkConnectorConfig.java | 58 +++-
connectors/camel-aws-ddb-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-ddb-kafka-sink-connector.adoc | 18 +-
.../awsddb/CamelAwsddbSinkConnectorConfig.java | 64 ++++-
.../camel-aws-ddbstream-kafka-connector/pom.xml | 12 +
...camel-aws-ddbstream-kafka-source-connector.adoc | 21 +-
.../CamelAwsddbstreamSourceConnectorConfig.java | 58 ++--
connectors/camel-aws-ec2-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-ec2-kafka-sink-connector.adoc | 13 +-
.../awsec2/CamelAwsec2SinkConnectorConfig.java | 32 ++-
connectors/camel-aws-ecs-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-ecs-kafka-sink-connector.adoc | 11 +-
.../awsecs/CamelAwsecsSinkConnectorConfig.java | 30 ++-
connectors/camel-aws-eks-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-eks-kafka-sink-connector.adoc | 11 +-
.../awseks/CamelAwseksSinkConnectorConfig.java | 30 ++-
connectors/camel-aws-iam-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-iam-kafka-sink-connector.adoc | 11 +-
.../awsiam/CamelAwsiamSinkConnectorConfig.java | 30 ++-
.../pom.xml | 12 +
...-aws-kinesis-firehose-kafka-sink-connector.adoc | 14 +-
...CamelAwskinesisfirehoseSinkConnectorConfig.java | 42 ++-
.../camel-aws-kinesis-kafka-connector/pom.xml | 12 +
.../camel-aws-kinesis-kafka-sink-connector.adoc | 14 +-
.../camel-aws-kinesis-kafka-source-connector.adoc | 23 +-
.../CamelAwskinesisSinkConnectorConfig.java | 42 ++-
.../CamelAwskinesisSourceConnectorConfig.java | 66 +++--
connectors/camel-aws-kms-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-kms-kafka-sink-connector.adoc | 11 +-
.../awskms/CamelAwskmsSinkConnectorConfig.java | 30 ++-
.../camel-aws-lambda-kafka-connector/pom.xml | 12 +
.../camel-aws-lambda-kafka-sink-connector.adoc | 15 +-
.../CamelAwslambdaSinkConnectorConfig.java | 46 +++-
connectors/camel-aws-mq-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-mq-kafka-sink-connector.adoc | 11 +-
.../awsmq/CamelAwsmqSinkConnectorConfig.java | 30 ++-
connectors/camel-aws-msk-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-msk-kafka-sink-connector.adoc | 11 +-
.../awsmsk/CamelAwsmskSinkConnectorConfig.java | 30 ++-
connectors/camel-aws-s3-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-s3-kafka-sink-connector.adoc | 40 ++-
.../docs/camel-aws-s3-kafka-source-connector.adoc | 41 ++-
.../awss3/CamelAwss3SinkConnectorConfig.java | 146 ++++++++--
.../awss3/CamelAwss3SourceConnectorConfig.java | 138 ++++++++--
connectors/camel-aws-sdb-kafka-connector/pom.xml | 12 +
connectors/camel-aws-ses-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-ses-kafka-sink-connector.adoc | 18 +-
.../awsses/CamelAwssesSinkConnectorConfig.java | 58 +++-
connectors/camel-aws-sns-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-sns-kafka-sink-connector.adoc | 23 +-
.../awssns/CamelAwssnsSinkConnectorConfig.java | 78 +++++-
connectors/camel-aws-sqs-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-sqs-kafka-sink-connector.adoc | 29 +-
.../docs/camel-aws-sqs-kafka-source-connector.adoc | 55 +++-
.../awssqs/CamelAwssqsSinkConnectorConfig.java | 102 ++++++-
.../awssqs/CamelAwssqsSourceConnectorConfig.java | 194 +++++++++++---
connectors/camel-aws-swf-kafka-connector/pom.xml | 12 +
.../docs/camel-aws-swf-kafka-sink-connector.adoc | 33 ++-
.../docs/camel-aws-swf-kafka-source-connector.adoc | 36 ++-
.../awsswf/CamelAwsswfSinkConnectorConfig.java | 118 ++++++--
.../awsswf/CamelAwsswfSourceConnectorConfig.java | 130 ++++++---
.../camel-aws-translate-kafka-connector/pom.xml | 12 +
.../camel-aws-translate-kafka-sink-connector.adoc | 14 +-
.../CamelAwstranslateSinkConnectorConfig.java | 42 ++-
connectors/camel-aws2-cw-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-cw-kafka-sink-connector.adoc | 18 +-
.../aws2cw/CamelAws2cwSinkConnectorConfig.java | 58 +++-
connectors/camel-aws2-ddb-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-ddb-kafka-sink-connector.adoc | 18 +-
.../aws2ddb/CamelAws2ddbSinkConnectorConfig.java | 64 ++++-
.../camel-aws2-ddbstream-kafka-connector/pom.xml | 12 +
...amel-aws2-ddbstream-kafka-source-connector.adoc | 21 +-
.../CamelAws2ddbstreamSourceConnectorConfig.java | 58 ++--
connectors/camel-aws2-ec2-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-ec2-kafka-sink-connector.adoc | 11 +-
.../aws2ec2/CamelAws2ec2SinkConnectorConfig.java | 30 ++-
connectors/camel-aws2-ecs-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-ecs-kafka-sink-connector.adoc | 19 +-
.../aws2ecs/CamelAws2ecsSinkConnectorConfig.java | 62 +++--
connectors/camel-aws2-eks-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-eks-kafka-sink-connector.adoc | 19 +-
.../aws2eks/CamelAws2eksSinkConnectorConfig.java | 62 +++--
connectors/camel-aws2-iam-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-iam-kafka-sink-connector.adoc | 19 +-
.../aws2iam/CamelAws2iamSinkConnectorConfig.java | 62 +++--
.../pom.xml | 20 +-
.../src/main/assembly/package.xml | 0
...aws2-kinesis-firehose-kafka-sink-connector.adoc | 49 ++++
.../CamelAws2kinesisfirehoseSinkConnector.java} | 8 +-
...amelAws2kinesisfirehoseSinkConnectorConfig.java | 129 +++++++++
.../CamelAws2kinesisfirehoseSinkTask.java} | 8 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../pom.xml | 20 +-
.../src/main/assembly/package.xml | 0
.../camel-aws2-kinesis-kafka-sink-connector.adoc | 49 ++++
...camel-aws2-kinesis-kafka-source-connector.adoc} | 41 +--
.../CamelAws2kinesisSinkConnector.java} | 8 +-
.../CamelAws2kinesisSinkConnectorConfig.java | 128 +++++++++
.../aws2kinesis/CamelAws2kinesisSinkTask.java} | 8 +-
.../CamelAws2kinesisSourceConnector.java} | 8 +-
.../CamelAws2kinesisSourceConnectorConfig.java | 241 +++++++++++++++++
.../aws2kinesis/CamelAws2kinesisSourceTask.java} | 8 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
connectors/camel-aws2-kms-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-kms-kafka-sink-connector.adoc | 19 +-
.../aws2kms/CamelAws2kmsSinkConnectorConfig.java | 62 +++--
.../pom.xml | 20 +-
.../src/main/assembly/package.xml | 0
.../camel-aws2-lambda-kafka-sink-connector.adoc | 51 ++++
.../aws2lambda/CamelAws2lambdaSinkConnector.java} | 8 +-
.../CamelAws2lambdaSinkConnectorConfig.java | 136 ++++++++++
.../aws2lambda/CamelAws2lambdaSinkTask.java} | 8 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
connectors/camel-aws2-mq-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-mq-kafka-sink-connector.adoc | 19 +-
.../aws2mq/CamelAws2mqSinkConnectorConfig.java | 62 +++--
connectors/camel-aws2-msk-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-msk-kafka-sink-connector.adoc | 19 +-
.../aws2msk/CamelAws2mskSinkConnectorConfig.java | 62 +++--
.../pom.xml | 20 +-
.../src/main/assembly/package.xml | 0
.../docs/camel-aws2-s3-kafka-sink-connector.adoc | 75 ++++++
.../docs/camel-aws2-s3-kafka-source-connector.adoc | 79 +++---
.../aws2s3/CamelAws2s3SinkConnector.java} | 8 +-
.../aws2s3/CamelAws2s3SinkConnectorConfig.java | 230 ++++++++++++++++
.../aws2s3/CamelAws2s3SinkTask.java} | 8 +-
.../aws2s3/CamelAws2s3SourceConnector.java} | 8 +-
.../aws2s3/CamelAws2s3SourceConnectorConfig.java | 296 +++++++++++++++++++++
.../aws2s3/CamelAws2s3SourceTask.java} | 8 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
connectors/camel-aws2-ses-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-ses-kafka-sink-connector.adoc | 18 +-
.../aws2ses/CamelAws2sesSinkConnectorConfig.java | 58 +++-
connectors/camel-aws2-sns-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-sns-kafka-sink-connector.adoc | 22 +-
.../aws2sns/CamelAws2snsSinkConnectorConfig.java | 74 +++++-
connectors/camel-aws2-sqs-kafka-connector/pom.xml | 12 +
.../docs/camel-aws2-sqs-kafka-sink-connector.adoc | 29 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 55 +++-
.../aws2sqs/CamelAws2sqsSinkConnectorConfig.java | 102 ++++++-
.../aws2sqs/CamelAws2sqsSourceConnectorConfig.java | 194 +++++++++++---
.../camel-aws2-translate-kafka-connector/pom.xml | 12 +
.../camel-aws2-translate-kafka-sink-connector.adoc | 22 +-
.../CamelAws2translateSinkConnectorConfig.java | 74 ++++--
.../camel-azure-blob-kafka-connector/pom.xml | 12 +
.../camel-azure-blob-kafka-sink-connector.adoc | 21 +-
.../camel-azure-blob-kafka-source-connector.adoc | 15 +-
.../CamelAzureblobSinkConnectorConfig.java | 76 ++++++
.../CamelAzureblobSourceConnectorConfig.java | 52 ++++
.../camel-azure-queue-kafka-connector/pom.xml | 12 +
.../camel-azure-queue-kafka-sink-connector.adoc | 12 +-
.../camel-azure-queue-kafka-source-connector.adoc | 8 +-
.../CamelAzurequeueSinkConnectorConfig.java | 40 +++
.../CamelAzurequeueSourceConnectorConfig.java | 24 ++
connectors/camel-bean-kafka-connector/pom.xml | 12 +
.../camel-bean-validator-kafka-connector/pom.xml | 12 +
connectors/camel-beanstalk-kafka-connector/pom.xml | 12 +
.../camel-beanstalk-kafka-source-connector.adoc | 4 +-
.../CamelBeanstalkSourceConnectorConfig.java | 4 +-
connectors/camel-bonita-kafka-connector/pom.xml | 12 +
connectors/camel-box-kafka-connector/pom.xml | 12 +
.../main/docs/camel-box-kafka-sink-connector.adoc | 19 +-
.../docs/camel-box-kafka-source-connector.adoc | 27 +-
.../box/CamelBoxSinkConnectorConfig.java | 68 ++++-
.../box/CamelBoxSourceConnectorConfig.java | 94 +++++--
connectors/camel-braintree-kafka-connector/pom.xml | 12 +
.../docs/camel-braintree-kafka-sink-connector.adoc | 5 +-
.../camel-braintree-kafka-source-connector.adoc | 19 +-
.../CamelBraintreeSinkConnectorConfig.java | 12 +-
.../CamelBraintreeSourceConnectorConfig.java | 56 ++--
connectors/camel-browse-kafka-connector/pom.xml | 12 +
.../camel-caffeine-cache-kafka-connector/pom.xml | 12 +
.../camel-caffeine-cache-kafka-sink-connector.adoc | 17 +-
.../CamelCaffeinecacheSinkConnectorConfig.java | 60 +++++
.../pom.xml | 12 +
...el-caffeine-loadcache-kafka-sink-connector.adoc | 17 +-
.../CamelCaffeineloadcacheSinkConnectorConfig.java | 60 +++++
.../camel-chatscript-kafka-connector/pom.xml | 12 +
connectors/camel-chunk-kafka-connector/pom.xml | 12 +
connectors/camel-class-kafka-connector/pom.xml | 12 +
connectors/camel-cm-sms-kafka-connector/pom.xml | 12 +
connectors/camel-cmis-kafka-connector/pom.xml | 12 +
connectors/camel-coap-kafka-connector/pom.xml | 12 +
connectors/camel-coap-tcp-kafka-connector/pom.xml | 12 +
connectors/camel-coaps-kafka-connector/pom.xml | 12 +
connectors/camel-coaps-tcp-kafka-connector/pom.xml | 12 +
connectors/camel-cometd-kafka-connector/pom.xml | 12 +
.../docs/camel-cometd-kafka-sink-connector.adoc | 2 +-
.../docs/camel-cometd-kafka-source-connector.adoc | 2 +-
.../cometd/CamelCometdSinkConnectorConfig.java | 8 +-
.../cometd/CamelCometdSourceConnectorConfig.java | 8 +-
connectors/camel-cometds-kafka-connector/pom.xml | 12 +
.../docs/camel-cometds-kafka-sink-connector.adoc | 2 +-
.../docs/camel-cometds-kafka-source-connector.adoc | 2 +-
.../cometds/CamelCometdsSinkConnectorConfig.java | 8 +-
.../cometds/CamelCometdsSourceConnectorConfig.java | 8 +-
connectors/camel-consul-kafka-connector/pom.xml | 12 +
.../docs/camel-consul-kafka-sink-connector.adoc | 26 +-
.../docs/camel-consul-kafka-source-connector.adoc | 33 ++-
.../consul/CamelConsulSinkConnectorConfig.java | 90 +++++--
.../consul/CamelConsulSourceConnectorConfig.java | 118 +++++---
.../camel-controlbus-kafka-connector/pom.xml | 12 +
connectors/camel-corda-kafka-connector/pom.xml | 12 +
.../docs/camel-corda-kafka-sink-connector.adoc | 5 +-
.../docs/camel-corda-kafka-source-connector.adoc | 11 +-
.../corda/CamelCordaSinkConnectorConfig.java | 12 +
.../corda/CamelCordaSourceConnectorConfig.java | 36 +++
connectors/camel-couchbase-kafka-connector/pom.xml | 12 +
.../camel-couchbase-kafka-source-connector.adoc | 4 +-
.../CamelCouchbaseSourceConnectorConfig.java | 4 +-
connectors/camel-couchdb-kafka-connector/pom.xml | 12 +
connectors/camel-cql-kafka-connector/pom.xml | 12 +
.../docs/camel-cql-kafka-source-connector.adoc | 4 +-
.../cql/CamelCqlSourceConnectorConfig.java | 4 +-
connectors/camel-cron-kafka-connector/pom.xml | 12 +
.../camel-crypto-cms-kafka-connector/pom.xml | 12 +
connectors/camel-crypto-kafka-connector/pom.xml | 12 +
.../docs/camel-crypto-kafka-sink-connector.adoc | 20 +-
.../crypto/CamelCryptoSinkConnectorConfig.java | 72 +++++
connectors/camel-cxf-kafka-connector/pom.xml | 12 +
connectors/camel-cxfrs-kafka-connector/pom.xml | 12 +
.../camel-dataformat-kafka-connector/pom.xml | 12 +
connectors/camel-dataset-kafka-connector/pom.xml | 12 +
.../camel-dataset-test-kafka-connector/pom.xml | 12 +
.../camel-debezium-mongodb-kafka-connector/pom.xml | 12 +
...el-debezium-mongodb-kafka-source-connector.adoc | 45 +++-
.../CamelDebeziummongodbSourceConnectorConfig.java | 166 +++++++++++-
.../camel-debezium-mysql-kafka-connector/pom.xml | 12 +
...amel-debezium-mysql-kafka-source-connector.adoc | 77 +++++-
.../CamelDebeziummysqlSourceConnectorConfig.java | 290 +++++++++++++++++++-
.../pom.xml | 12 +
...l-debezium-postgres-kafka-source-connector.adoc | 71 ++++-
...CamelDebeziumpostgresSourceConnectorConfig.java | 270 ++++++++++++++++++-
.../pom.xml | 12 +
...-debezium-sqlserver-kafka-source-connector.adoc | 49 +++-
...amelDebeziumsqlserverSourceConnectorConfig.java | 188 +++++++++++++
.../camel-digitalocean-kafka-connector/pom.xml | 12 +
connectors/camel-direct-kafka-connector/pom.xml | 12 +
connectors/camel-direct-vm-kafka-connector/pom.xml | 12 +
connectors/camel-disruptor-kafka-connector/pom.xml | 12 +
.../docs/camel-disruptor-kafka-sink-connector.adoc | 3 +-
.../camel-disruptor-kafka-source-connector.adoc | 3 +-
.../CamelDisruptorSinkConnectorConfig.java | 4 -
.../CamelDisruptorSourceConnectorConfig.java | 4 -
.../camel-disruptor-vm-kafka-connector/pom.xml | 12 +
.../camel-disruptor-vm-kafka-sink-connector.adoc | 3 +-
.../camel-disruptor-vm-kafka-source-connector.adoc | 3 +-
.../CamelDisruptorvmSinkConnectorConfig.java | 4 -
.../CamelDisruptorvmSourceConnectorConfig.java | 4 -
connectors/camel-dns-kafka-connector/pom.xml | 12 +
connectors/camel-docker-kafka-connector/pom.xml | 12 +
.../docs/camel-docker-kafka-sink-connector.adoc | 19 +-
.../docs/camel-docker-kafka-source-connector.adoc | 19 +-
.../docker/CamelDockerSinkConnectorConfig.java | 68 +++++
.../docker/CamelDockerSourceConnectorConfig.java | 68 +++++
connectors/camel-dozer-kafka-connector/pom.xml | 12 +
connectors/camel-drill-kafka-connector/pom.xml | 12 +
connectors/camel-dropbox-kafka-connector/pom.xml | 12 +
connectors/camel-ehcache-kafka-connector/pom.xml | 12 +
.../docs/camel-ehcache-kafka-sink-connector.adoc | 14 +-
.../docs/camel-ehcache-kafka-source-connector.adoc | 15 +-
.../ehcache/CamelEhcacheSinkConnectorConfig.java | 42 ++-
.../ehcache/CamelEhcacheSourceConnectorConfig.java | 46 +++-
.../pom.xml | 12 +
connectors/camel-elsql-kafka-connector/pom.xml | 12 +
.../docs/camel-elsql-kafka-sink-connector.adoc | 2 +-
.../docs/camel-elsql-kafka-source-connector.adoc | 4 +-
.../elsql/CamelElsqlSinkConnectorConfig.java | 2 +-
.../elsql/CamelElsqlSourceConnectorConfig.java | 4 +-
connectors/camel-etcd-keys-kafka-connector/pom.xml | 12 +
.../docs/camel-etcd-keys-kafka-sink-connector.adoc | 14 +-
.../etcdkeys/CamelEtcdkeysSinkConnectorConfig.java | 42 ++-
.../camel-etcd-stats-kafka-connector/pom.xml | 12 +
.../camel-etcd-stats-kafka-sink-connector.adoc | 16 +-
.../camel-etcd-stats-kafka-source-connector.adoc | 21 +-
.../CamelEtcdstatsSinkConnectorConfig.java | 44 ++-
.../CamelEtcdstatsSourceConnectorConfig.java | 52 ++--
.../camel-etcd-watch-kafka-connector/pom.xml | 12 +
.../camel-etcd-watch-kafka-source-connector.adoc | 15 +-
.../CamelEtcdwatchSourceConnectorConfig.java | 46 +++-
.../camel-eventadmin-kafka-connector/pom.xml | 123 ---------
.../src/main/assembly/package.xml | 57 ----
.../camel-eventadmin-kafka-sink-connector.adoc | 34 ---
.../camel-eventadmin-kafka-source-connector.adoc | 36 ---
.../eventadmin/CamelEventadminSinkConnector.java | 35 ---
.../CamelEventadminSinkConnectorConfig.java | 76 ------
.../eventadmin/CamelEventadminSinkTask.java | 39 ---
.../eventadmin/CamelEventadminSourceConnector.java | 35 ---
.../CamelEventadminSourceConnectorConfig.java | 84 ------
.../eventadmin/CamelEventadminSourceTask.java | 39 ---
.../src/main/resources/META-INF/LICENSE.txt | 203 --------------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-exec-kafka-connector/pom.xml | 12 +
connectors/camel-facebook-kafka-connector/pom.xml | 12 +
.../docs/camel-facebook-kafka-sink-connector.adoc | 29 +-
.../camel-facebook-kafka-source-connector.adoc | 29 +-
.../facebook/CamelFacebookSinkConnectorConfig.java | 108 ++++++++
.../CamelFacebookSourceConnectorConfig.java | 108 ++++++++
connectors/camel-fhir-kafka-connector/pom.xml | 12 +
.../main/docs/camel-fhir-kafka-sink-connector.adoc | 27 +-
.../docs/camel-fhir-kafka-source-connector.adoc | 39 ++-
.../fhir/CamelFhirSinkConnectorConfig.java | 100 ++++++-
.../fhir/CamelFhirSourceConnectorConfig.java | 136 ++++++++--
connectors/camel-file-kafka-connector/pom.xml | 12 +
.../docs/camel-file-kafka-source-connector.adoc | 4 +-
.../file/CamelFileSourceConnectorConfig.java | 4 +-
.../camel-file-watch-kafka-connector/pom.xml | 12 +
connectors/camel-flatpack-kafka-connector/pom.xml | 12 +
.../camel-flatpack-kafka-source-connector.adoc | 4 +-
.../CamelFlatpackSourceConnectorConfig.java | 4 +-
connectors/camel-flink-kafka-connector/pom.xml | 12 +
connectors/camel-fop-kafka-connector/pom.xml | 12 +
.../camel-freemarker-kafka-connector/pom.xml | 12 +
connectors/camel-ftp-kafka-connector/pom.xml | 12 +
.../docs/camel-ftp-kafka-source-connector.adoc | 10 +-
.../ftp/CamelFtpSourceConnectorConfig.java | 28 +-
connectors/camel-ftps-kafka-connector/pom.xml | 12 +
.../docs/camel-ftps-kafka-source-connector.adoc | 10 +-
.../ftps/CamelFtpsSourceConnectorConfig.java | 28 +-
connectors/camel-ganglia-kafka-connector/pom.xml | 12 +
.../docs/camel-ganglia-kafka-sink-connector.adoc | 14 +-
.../ganglia/CamelGangliaSinkConnectorConfig.java | 48 ++++
connectors/camel-geocoder-kafka-connector/pom.xml | 12 +
connectors/camel-git-kafka-connector/pom.xml | 12 +
connectors/camel-github-kafka-connector/pom.xml | 12 +
.../camel-google-bigquery-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../camel-google-calendar-kafka-connector/pom.xml | 12 +
...camel-google-calendar-kafka-sink-connector.adoc | 17 +-
...mel-google-calendar-kafka-source-connector.adoc | 21 +-
.../CamelGooglecalendarSinkConnectorConfig.java | 60 ++++-
.../CamelGooglecalendarSourceConnectorConfig.java | 64 ++++-
.../pom.xml | 12 +
...gle-calendar-stream-kafka-source-connector.adoc | 17 +-
...lGooglecalendarstreamSourceConnectorConfig.java | 48 +++-
.../camel-google-drive-kafka-connector/pom.xml | 12 +
.../camel-google-drive-kafka-sink-connector.adoc | 14 +-
.../camel-google-drive-kafka-source-connector.adoc | 18 +-
.../CamelGoogledriveSinkConnectorConfig.java | 48 +++-
.../CamelGoogledriveSourceConnectorConfig.java | 52 +++-
.../camel-google-mail-kafka-connector/pom.xml | 12 +
.../camel-google-mail-kafka-sink-connector.adoc | 13 +-
.../camel-google-mail-kafka-source-connector.adoc | 17 +-
.../CamelGooglemailSinkConnectorConfig.java | 44 ++-
.../CamelGooglemailSourceConnectorConfig.java | 48 +++-
.../pom.xml | 12 +
...-google-mail-stream-kafka-source-connector.adoc | 15 +-
...CamelGooglemailstreamSourceConnectorConfig.java | 40 ++-
.../camel-google-pubsub-kafka-connector/pom.xml | 12 +
.../camel-google-pubsub-kafka-sink-connector.adoc | 9 +-
...camel-google-pubsub-kafka-source-connector.adoc | 7 +-
.../CamelGooglepubsubSinkConnectorConfig.java | 28 +-
.../CamelGooglepubsubSourceConnectorConfig.java | 20 +-
.../camel-google-sheets-kafka-connector/pom.xml | 12 +
.../camel-google-sheets-kafka-sink-connector.adoc | 13 +-
...camel-google-sheets-kafka-source-connector.adoc | 17 +-
.../CamelGooglesheetsSinkConnectorConfig.java | 44 ++-
.../CamelGooglesheetsSourceConnectorConfig.java | 48 +++-
.../pom.xml | 12 +
...oogle-sheets-stream-kafka-source-connector.adoc | 19 +-
...melGooglesheetsstreamSourceConnectorConfig.java | 56 +++-
connectors/camel-gora-kafka-connector/pom.xml | 12 +
connectors/camel-grape-kafka-connector/pom.xml | 12 +
connectors/camel-graphql-kafka-connector/pom.xml | 12 +
connectors/camel-grpc-kafka-connector/pom.xml | 12 +
.../camel-guava-eventbus-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
.../camel-hazelcast-list-kafka-connector/pom.xml | 12 +
.../camel-hazelcast-map-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../camel-hazelcast-queue-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
.../camel-hazelcast-seda-kafka-connector/pom.xml | 12 +
.../camel-hazelcast-set-kafka-connector/pom.xml | 12 +
.../camel-hazelcast-topic-kafka-connector/pom.xml | 12 +
connectors/camel-hbase-kafka-connector/pom.xml | 12 +
connectors/camel-hdfs-kafka-connector/pom.xml | 12 +
.../docs/camel-hdfs-kafka-source-connector.adoc | 4 +-
.../hdfs/CamelHdfsSourceConnectorConfig.java | 4 +-
connectors/camel-hipchat-kafka-connector/pom.xml | 12 +
.../docs/camel-hipchat-kafka-source-connector.adoc | 2 +-
.../hipchat/CamelHipchatSourceConnectorConfig.java | 2 +-
connectors/camel-http-kafka-connector/pom.xml | 12 +
connectors/camel-https-kafka-connector/pom.xml | 12 +
.../camel-iec60870-client-kafka-connector/pom.xml | 12 +
.../camel-iec60870-server-kafka-connector/pom.xml | 12 +
.../camel-ignite-cache-kafka-connector/pom.xml | 12 +
.../camel-ignite-compute-kafka-connector/pom.xml | 12 +
.../camel-ignite-events-kafka-connector/pom.xml | 12 +
.../camel-ignite-idgen-kafka-connector/pom.xml | 12 +
.../camel-ignite-messaging-kafka-connector/pom.xml | 12 +
.../camel-ignite-queue-kafka-connector/pom.xml | 12 +
.../camel-ignite-set-kafka-connector/pom.xml | 12 +
connectors/camel-imap-kafka-connector/pom.xml | 12 +
.../main/docs/camel-imap-kafka-sink-connector.adoc | 29 +-
.../docs/camel-imap-kafka-source-connector.adoc | 39 ++-
.../imap/CamelImapSinkConnectorConfig.java | 96 ++++++-
.../imap/CamelImapSourceConnectorConfig.java | 130 ++++++++-
connectors/camel-imaps-kafka-connector/pom.xml | 12 +
.../docs/camel-imaps-kafka-sink-connector.adoc | 29 +-
.../docs/camel-imaps-kafka-source-connector.adoc | 39 ++-
.../imaps/CamelImapsSinkConnectorConfig.java | 96 ++++++-
.../imaps/CamelImapsSourceConnectorConfig.java | 130 ++++++++-
.../camel-infinispan-kafka-connector/pom.xml | 12 +
.../camel-infinispan-kafka-sink-connector.adoc | 17 +-
.../camel-infinispan-kafka-source-connector.adoc | 21 +-
.../CamelInfinispanSinkConnectorConfig.java | 48 +++-
.../CamelInfinispanSourceConnectorConfig.java | 64 ++++-
connectors/camel-influxdb-kafka-connector/pom.xml | 12 +
.../docs/camel-influxdb-kafka-sink-connector.adoc | 3 +-
.../influxdb/CamelInfluxdbSinkConnectorConfig.java | 4 +
connectors/camel-iota-kafka-connector/pom.xml | 12 +
connectors/camel-ipfs-kafka-connector/pom.xml | 12 +
connectors/camel-irc-kafka-connector/pom.xml | 12 +
connectors/camel-ironmq-kafka-connector/pom.xml | 12 +
.../docs/camel-ironmq-kafka-source-connector.adoc | 4 +-
.../ironmq/CamelIronmqSourceConnectorConfig.java | 4 +-
connectors/camel-jbpm-kafka-connector/pom.xml | 12 +
connectors/camel-jcache-kafka-connector/pom.xml | 12 +
connectors/camel-jclouds-kafka-connector/pom.xml | 12 +
connectors/camel-jcr-kafka-connector/pom.xml | 12 +
connectors/camel-jdbc-kafka-connector/pom.xml | 12 +
connectors/camel-jetty-kafka-connector/pom.xml | 12 +
connectors/camel-jgroups-kafka-connector/pom.xml | 12 +
.../camel-jgroups-raft-kafka-connector/pom.xml | 12 +
connectors/camel-jing-kafka-connector/pom.xml | 12 +
connectors/camel-jira-kafka-connector/pom.xml | 12 +
.../main/docs/camel-jira-kafka-sink-connector.adoc | 10 +-
.../docs/camel-jira-kafka-source-connector.adoc | 10 +-
.../jira/CamelJiraSinkConnectorConfig.java | 32 +++
.../jira/CamelJiraSourceConnectorConfig.java | 32 +++
connectors/camel-jms-kafka-connector/pom.xml | 12 +
.../main/docs/camel-jms-kafka-sink-connector.adoc | 29 +-
.../docs/camel-jms-kafka-source-connector.adoc | 25 +-
.../jms/CamelJmsSinkConnectorConfig.java | 68 +++--
.../jms/CamelJmsSourceConnectorConfig.java | 68 +++--
connectors/camel-jmx-kafka-connector/pom.xml | 12 +
.../docs/camel-jmx-kafka-source-connector.adoc | 6 +-
.../jmx/CamelJmxSourceConnectorConfig.java | 24 +-
connectors/camel-jolt-kafka-connector/pom.xml | 12 +
connectors/camel-jooq-kafka-connector/pom.xml | 12 +
.../main/docs/camel-jooq-kafka-sink-connector.adoc | 5 +-
.../docs/camel-jooq-kafka-source-connector.adoc | 8 +-
.../jooq/CamelJooqSinkConnectorConfig.java | 12 +
.../jooq/CamelJooqSourceConnectorConfig.java | 12 +-
connectors/camel-jpa-kafka-connector/pom.xml | 12 +
.../docs/camel-jpa-kafka-source-connector.adoc | 4 +-
.../jpa/CamelJpaSourceConnectorConfig.java | 4 +-
connectors/camel-jslt-kafka-connector/pom.xml | 12 +
.../camel-json-validator-kafka-connector/pom.xml | 12 +
connectors/camel-jt400-kafka-connector/pom.xml | 12 +
.../docs/camel-jt400-kafka-source-connector.adoc | 4 +-
.../jt400/CamelJt400SourceConnectorConfig.java | 4 +-
connectors/camel-kafka-kafka-connector/pom.xml | 12 +
.../docs/camel-kafka-kafka-sink-connector.adoc | 74 +++++-
.../docs/camel-kafka-kafka-source-connector.adoc | 58 +++-
.../kafka/CamelKafkaSinkConnectorConfig.java | 264 +++++++++++++++++-
.../kafka/CamelKafkaSourceConnectorConfig.java | 218 ++++++++++++++-
.../pom.xml | 12 +
.../pom.xml | 12 +
.../camel-kubernetes-hpa-kafka-connector/pom.xml | 12 +
.../camel-kubernetes-job-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../camel-kubernetes-nodes-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
.../camel-kubernetes-pods-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
connectors/camel-kudu-kafka-connector/pom.xml | 12 +
connectors/camel-language-kafka-connector/pom.xml | 12 +
connectors/camel-ldap-kafka-connector/pom.xml | 12 +
connectors/camel-ldif-kafka-connector/pom.xml | 12 +
connectors/camel-log-kafka-connector/pom.xml | 12 +
connectors/camel-lpr-kafka-connector/pom.xml | 12 +
connectors/camel-lucene-kafka-connector/pom.xml | 12 +
.../docs/camel-lucene-kafka-sink-connector.adoc | 6 +-
.../lucene/CamelLuceneSinkConnectorConfig.java | 16 ++
.../camel-lumberjack-kafka-connector/pom.xml | 12 +
connectors/camel-master-kafka-connector/pom.xml | 12 +
connectors/camel-metrics-kafka-connector/pom.xml | 12 +
.../camel-micrometer-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../camel-milo-client-kafka-connector/pom.xml | 12 +
.../camel-milo-client-kafka-sink-connector.adoc | 31 ++-
.../camel-milo-client-kafka-source-connector.adoc | 31 ++-
.../CamelMiloclientSinkConnectorConfig.java | 108 ++++++--
.../CamelMiloclientSourceConnectorConfig.java | 108 ++++++--
.../camel-milo-server-kafka-connector/pom.xml | 12 +
.../camel-milo-server-kafka-sink-connector.adoc | 6 +-
.../camel-milo-server-kafka-source-connector.adoc | 6 +-
.../CamelMiloserverSinkConnectorConfig.java | 18 +-
.../CamelMiloserverSourceConnectorConfig.java | 18 +-
connectors/camel-mina-kafka-connector/pom.xml | 12 +
.../main/docs/camel-mina-kafka-sink-connector.adoc | 22 +-
.../docs/camel-mina-kafka-source-connector.adoc | 23 +-
.../mina/CamelMinaSinkConnectorConfig.java | 80 ++++++
.../mina/CamelMinaSourceConnectorConfig.java | 84 ++++++
connectors/camel-mllp-kafka-connector/pom.xml | 12 +
.../main/docs/camel-mllp-kafka-sink-connector.adoc | 7 +-
.../docs/camel-mllp-kafka-source-connector.adoc | 9 +-
.../mllp/CamelMllpSinkConnectorConfig.java | 20 +-
.../mllp/CamelMllpSourceConnectorConfig.java | 28 +-
connectors/camel-mock-kafka-connector/pom.xml | 12 +
.../camel-mongodb-gridfs-kafka-connector/pom.xml | 12 +
connectors/camel-mongodb-kafka-connector/pom.xml | 12 +
connectors/camel-msv-kafka-connector/pom.xml | 12 +
connectors/camel-mustache-kafka-connector/pom.xml | 12 +
connectors/camel-mvel-kafka-connector/pom.xml | 12 +
.../camel-mybatis-bean-kafka-connector/pom.xml | 12 +
connectors/camel-mybatis-kafka-connector/pom.xml | 12 +
.../docs/camel-mybatis-kafka-source-connector.adoc | 4 +-
.../mybatis/CamelMybatisSourceConnectorConfig.java | 4 +-
connectors/camel-nagios-kafka-connector/pom.xml | 12 +
.../docs/camel-nagios-kafka-sink-connector.adoc | 6 +-
.../nagios/CamelNagiosSinkConnectorConfig.java | 16 ++
connectors/camel-nats-kafka-connector/pom.xml | 12 +
.../main/docs/camel-nats-kafka-sink-connector.adoc | 5 +-
.../docs/camel-nats-kafka-source-connector.adoc | 5 +-
.../nats/CamelNatsSinkConnectorConfig.java | 6 +-
.../nats/CamelNatsSourceConnectorConfig.java | 6 +-
.../camel-netty-http-kafka-connector/pom.xml | 12 +
.../camel-netty-http-kafka-sink-connector.adoc | 50 +++-
.../camel-netty-http-kafka-source-connector.adoc | 54 +++-
.../CamelNettyhttpSinkConnectorConfig.java | 192 +++++++++++++
.../CamelNettyhttpSourceConnectorConfig.java | 208 +++++++++++++++
connectors/camel-netty-kafka-connector/pom.xml | 12 +
.../docs/camel-netty-kafka-sink-connector.adoc | 52 +++-
.../docs/camel-netty-kafka-source-connector.adoc | 56 +++-
.../netty/CamelNettySinkConnectorConfig.java | 200 +++++++++++++-
.../netty/CamelNettySourceConnectorConfig.java | 216 ++++++++++++++-
connectors/camel-nitrite-kafka-connector/pom.xml | 12 +
connectors/camel-nsq-kafka-connector/pom.xml | 12 +
.../main/docs/camel-nsq-kafka-sink-connector.adoc | 2 +-
.../docs/camel-nsq-kafka-source-connector.adoc | 2 +-
.../nsq/CamelNsqSinkConnectorConfig.java | 2 +-
.../nsq/CamelNsqSourceConnectorConfig.java | 2 +-
connectors/camel-olingo2-kafka-connector/pom.xml | 12 +
.../docs/camel-olingo2-kafka-sink-connector.adoc | 18 +-
.../docs/camel-olingo2-kafka-source-connector.adoc | 23 +-
.../olingo2/CamelOlingo2SinkConnectorConfig.java | 64 ++++-
.../olingo2/CamelOlingo2SourceConnectorConfig.java | 72 ++++-
connectors/camel-olingo4-kafka-connector/pom.xml | 12 +
.../docs/camel-olingo4-kafka-sink-connector.adoc | 18 +-
.../docs/camel-olingo4-kafka-source-connector.adoc | 23 +-
.../olingo4/CamelOlingo4SinkConnectorConfig.java | 64 ++++-
.../olingo4/CamelOlingo4SourceConnectorConfig.java | 72 ++++-
.../pom.xml | 12 +
.../camel-openshift-builds-kafka-connector/pom.xml | 12 +
.../camel-openstack-cinder-kafka-connector/pom.xml | 12 +
.../camel-openstack-glance-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../pom.xml | 12 +
.../camel-openstack-nova-kafka-connector/pom.xml | 12 +
.../camel-openstack-swift-kafka-connector/pom.xml | 12 +
.../camel-optaplanner-kafka-connector/pom.xml | 12 +
connectors/camel-paho-kafka-connector/pom.xml | 12 +
.../main/docs/camel-paho-kafka-sink-connector.adoc | 29 +-
.../docs/camel-paho-kafka-source-connector.adoc | 29 +-
.../paho/CamelPahoSinkConnectorConfig.java | 102 ++++++-
.../paho/CamelPahoSourceConnectorConfig.java | 102 ++++++-
.../camel-paxlogging-kafka-connector/pom.xml | 123 ---------
.../camel-paxlogging-kafka-source-connector.adoc | 35 ---
.../paxlogging/CamelPaxloggingSourceConnector.java | 35 ---
.../CamelPaxloggingSourceConnectorConfig.java | 80 ------
.../paxlogging/CamelPaxloggingSourceTask.java | 39 ---
connectors/camel-pdf-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
...pg-replication-slot-kafka-source-connector.adoc | 4 +-
...amelPgreplicationslotSourceConnectorConfig.java | 4 +-
connectors/camel-pgevent-kafka-connector/pom.xml | 12 +
.../camel-platform-http-kafka-connector/pom.xml | 12 +
...camel-platform-http-kafka-source-connector.adoc | 4 +-
.../CamelPlatformhttpSourceConnectorConfig.java | 8 +
connectors/camel-pop3-kafka-connector/pom.xml | 12 +
.../main/docs/camel-pop3-kafka-sink-connector.adoc | 29 +-
.../docs/camel-pop3-kafka-source-connector.adoc | 39 ++-
.../pop3/CamelPop3SinkConnectorConfig.java | 96 ++++++-
.../pop3/CamelPop3SourceConnectorConfig.java | 130 ++++++++-
connectors/camel-pop3s-kafka-connector/pom.xml | 12 +
.../docs/camel-pop3s-kafka-sink-connector.adoc | 29 +-
.../docs/camel-pop3s-kafka-source-connector.adoc | 39 ++-
.../pop3s/CamelPop3sSinkConnectorConfig.java | 96 ++++++-
.../pop3s/CamelPop3sSourceConnectorConfig.java | 130 ++++++++-
connectors/camel-pubnub-kafka-connector/pom.xml | 12 +
connectors/camel-pulsar-kafka-connector/pom.xml | 12 +
.../docs/camel-pulsar-kafka-sink-connector.adoc | 19 +-
.../docs/camel-pulsar-kafka-source-connector.adoc | 26 +-
.../pulsar/CamelPulsarSinkConnectorConfig.java | 62 ++++-
.../pulsar/CamelPulsarSourceConnectorConfig.java | 72 ++++-
connectors/camel-quartz-kafka-connector/pom.xml | 12 +
connectors/camel-quickfix-kafka-connector/pom.xml | 12 +
.../docs/camel-quickfix-kafka-sink-connector.adoc | 3 +-
.../camel-quickfix-kafka-source-connector.adoc | 3 +-
.../quickfix/CamelQuickfixSinkConnectorConfig.java | 4 -
.../CamelQuickfixSourceConnectorConfig.java | 4 -
connectors/camel-rabbitmq-kafka-connector/pom.xml | 12 +
.../docs/camel-rabbitmq-kafka-sink-connector.adoc | 6 +-
.../camel-rabbitmq-kafka-source-connector.adoc | 6 +-
.../rabbitmq/CamelRabbitmqSinkConnectorConfig.java | 16 ++
.../CamelRabbitmqSourceConnectorConfig.java | 16 ++
.../camel-reactive-streams-kafka-connector/pom.xml | 12 +
...amel-reactive-streams-kafka-sink-connector.adoc | 7 +-
...el-reactive-streams-kafka-source-connector.adoc | 7 +-
.../CamelReactivestreamsSinkConnectorConfig.java | 20 +-
.../CamelReactivestreamsSourceConnectorConfig.java | 20 +-
connectors/camel-ref-kafka-connector/pom.xml | 12 +
connectors/camel-rest-api-kafka-connector/pom.xml | 12 +
connectors/camel-rest-kafka-connector/pom.xml | 12 +
.../camel-rest-openapi-kafka-connector/pom.xml | 12 +
.../camel-rest-swagger-kafka-connector/pom.xml | 12 +
.../camel-robotframework-kafka-connector/pom.xml | 12 +
.../camel-robotframework-kafka-sink-connector.adoc | 47 +++-
...amel-robotframework-kafka-source-connector.adoc | 51 +++-
.../CamelRobotframeworkSinkConnectorConfig.java | 180 +++++++++++++
.../CamelRobotframeworkSourceConnectorConfig.java | 184 ++++++++++++-
connectors/camel-rss-kafka-connector/pom.xml | 12 +
.../docs/camel-rss-kafka-source-connector.adoc | 4 +-
.../rss/CamelRssSourceConnectorConfig.java | 4 +-
connectors/camel-saga-kafka-connector/pom.xml | 12 +
.../camel-salesforce-kafka-connector/pom.xml | 12 +
.../camel-salesforce-kafka-sink-connector.adoc | 44 ++-
.../camel-salesforce-kafka-source-connector.adoc | 44 ++-
.../CamelSalesforceSinkConnectorConfig.java | 168 +++++++++++-
.../CamelSalesforceSourceConnectorConfig.java | 168 +++++++++++-
.../camel-sap-netweaver-kafka-connector/pom.xml | 12 +
connectors/camel-scheduler-kafka-connector/pom.xml | 12 +
.../camel-scheduler-kafka-source-connector.adoc | 4 +-
.../CamelSchedulerSourceConnectorConfig.java | 4 +-
.../camel-schematron-kafka-connector/pom.xml | 12 +
connectors/camel-scp-kafka-connector/pom.xml | 12 +
connectors/camel-seda-kafka-connector/pom.xml | 12 +
connectors/camel-service-kafka-connector/pom.xml | 12 +
.../camel-servicenow-kafka-connector/pom.xml | 12 +
.../camel-servicenow-kafka-sink-connector.adoc | 43 ++-
.../CamelServicenowSinkConnectorConfig.java | 156 ++++++++++-
connectors/camel-servlet-kafka-connector/pom.xml | 12 +
connectors/camel-sftp-kafka-connector/pom.xml | 12 +
.../docs/camel-sftp-kafka-source-connector.adoc | 10 +-
.../sftp/CamelSftpSourceConnectorConfig.java | 28 +-
connectors/camel-sip-kafka-connector/pom.xml | 12 +
connectors/camel-sips-kafka-connector/pom.xml | 12 +
.../camel-sjms-batch-kafka-connector/pom.xml | 12 +
connectors/camel-sjms-kafka-connector/pom.xml | 12 +
connectors/camel-sjms2-kafka-connector/pom.xml | 12 +
connectors/camel-slack-kafka-connector/pom.xml | 12 +
.../docs/camel-slack-kafka-source-connector.adoc | 4 +-
.../slack/CamelSlackSourceConnectorConfig.java | 4 +-
connectors/camel-smpp-kafka-connector/pom.xml | 12 +
.../main/docs/camel-smpp-kafka-sink-connector.adoc | 35 ++-
.../docs/camel-smpp-kafka-source-connector.adoc | 22 +-
.../smpp/CamelSmppSinkConnectorConfig.java | 132 +++++++++
.../smpp/CamelSmppSourceConnectorConfig.java | 80 ++++++
connectors/camel-smpps-kafka-connector/pom.xml | 12 +
.../docs/camel-smpps-kafka-sink-connector.adoc | 35 ++-
.../docs/camel-smpps-kafka-source-connector.adoc | 22 +-
.../smpps/CamelSmppsSinkConnectorConfig.java | 132 +++++++++
.../smpps/CamelSmppsSourceConnectorConfig.java | 80 ++++++
connectors/camel-smtp-kafka-connector/pom.xml | 12 +
.../main/docs/camel-smtp-kafka-sink-connector.adoc | 29 +-
.../docs/camel-smtp-kafka-source-connector.adoc | 39 ++-
.../smtp/CamelSmtpSinkConnectorConfig.java | 96 ++++++-
.../smtp/CamelSmtpSourceConnectorConfig.java | 130 ++++++++-
connectors/camel-smtps-kafka-connector/pom.xml | 12 +
.../docs/camel-smtps-kafka-sink-connector.adoc | 29 +-
.../docs/camel-smtps-kafka-source-connector.adoc | 39 ++-
.../smtps/CamelSmtpsSinkConnectorConfig.java | 96 ++++++-
.../smtps/CamelSmtpsSourceConnectorConfig.java | 130 ++++++++-
connectors/camel-snmp-kafka-connector/pom.xml | 12 +
.../docs/camel-snmp-kafka-source-connector.adoc | 2 +-
.../snmp/CamelSnmpSourceConnectorConfig.java | 2 +-
connectors/camel-solr-kafka-connector/pom.xml | 12 +
connectors/camel-solrcloud-kafka-connector/pom.xml | 12 +
connectors/camel-solrs-kafka-connector/pom.xml | 12 +
connectors/camel-soroush-kafka-connector/pom.xml | 12 +
connectors/camel-spark-kafka-connector/pom.xml | 12 +
.../camel-spark-rest-kafka-connector/pom.xml | 123 ---------
.../camel-spark-rest-kafka-source-connector.adoc | 53 ----
.../sparkrest/CamelSparkrestSourceConnector.java | 35 ---
.../CamelSparkrestSourceConnectorConfig.java | 152 -----------
.../sparkrest/CamelSparkrestSourceTask.java | 39 ---
connectors/camel-splunk-kafka-connector/pom.xml | 12 +
.../docs/camel-splunk-kafka-source-connector.adoc | 4 +-
.../splunk/CamelSplunkSourceConnectorConfig.java | 4 +-
.../camel-spring-batch-kafka-connector/pom.xml | 12 +
.../camel-spring-event-kafka-connector/pom.xml | 12 +
.../pom.xml | 12 +
.../camel-spring-ldap-kafka-connector/pom.xml | 12 +
.../camel-spring-redis-kafka-connector/pom.xml | 12 +
connectors/camel-spring-ws-kafka-connector/pom.xml | 12 +
connectors/camel-sql-kafka-connector/pom.xml | 12 +
.../main/docs/camel-sql-kafka-sink-connector.adoc | 2 +-
.../docs/camel-sql-kafka-source-connector.adoc | 4 +-
.../sql/CamelSqlSinkConnectorConfig.java | 2 +-
.../sql/CamelSqlSourceConnectorConfig.java | 4 +-
.../camel-sql-stored-kafka-connector/pom.xml | 12 +
connectors/camel-ssh-kafka-connector/pom.xml | 12 +
.../main/docs/camel-ssh-kafka-sink-connector.adoc | 17 +-
.../docs/camel-ssh-kafka-source-connector.adoc | 20 +-
.../ssh/CamelSshSinkConnectorConfig.java | 30 +--
.../ssh/CamelSshSourceConnectorConfig.java | 38 +--
connectors/camel-stax-kafka-connector/pom.xml | 12 +
connectors/camel-stomp-kafka-connector/pom.xml | 12 +
.../docs/camel-stomp-kafka-sink-connector.adoc | 11 +-
.../docs/camel-stomp-kafka-source-connector.adoc | 11 +-
.../stomp/CamelStompSinkConnectorConfig.java | 20 +-
.../stomp/CamelStompSourceConnectorConfig.java | 20 +-
connectors/camel-stream-kafka-connector/pom.xml | 12 +
.../camel-string-template-kafka-connector/pom.xml | 12 +
connectors/camel-stub-kafka-connector/pom.xml | 12 +
connectors/camel-telegram-kafka-connector/pom.xml | 12 +
.../camel-telegram-kafka-source-connector.adoc | 8 +-
.../CamelTelegramSourceConnectorConfig.java | 20 +-
connectors/camel-thrift-kafka-connector/pom.xml | 12 +
connectors/camel-tika-kafka-connector/pom.xml | 12 +
connectors/camel-timer-kafka-connector/pom.xml | 12 +
.../docs/camel-timer-kafka-source-connector.adoc | 4 +-
.../timer/CamelTimerSourceConnectorConfig.java | 4 +-
connectors/camel-twilio-kafka-connector/pom.xml | 12 +
.../docs/camel-twilio-kafka-source-connector.adoc | 4 +-
.../twilio/CamelTwilioSourceConnectorConfig.java | 4 +-
.../pom.xml | 12 +
...itter-directmessage-kafka-source-connector.adoc | 12 +-
...lTwitterdirectmessageSourceConnectorConfig.java | 42 +--
.../camel-twitter-search-kafka-connector/pom.xml | 12 +
...amel-twitter-search-kafka-source-connector.adoc | 12 +-
.../CamelTwittersearchSourceConnectorConfig.java | 42 +--
.../camel-twitter-timeline-kafka-connector/pom.xml | 12 +
...el-twitter-timeline-kafka-source-connector.adoc | 12 +-
.../CamelTwittertimelineSourceConnectorConfig.java | 42 +--
connectors/camel-undertow-kafka-connector/pom.xml | 12 +
.../docs/camel-undertow-kafka-sink-connector.adoc | 10 +-
.../camel-undertow-kafka-source-connector.adoc | 10 +-
.../undertow/CamelUndertowSinkConnectorConfig.java | 32 ++-
.../CamelUndertowSourceConnectorConfig.java | 32 ++-
connectors/camel-validator-kafka-connector/pom.xml | 12 +
connectors/camel-velocity-kafka-connector/pom.xml | 12 +
connectors/camel-vertx-kafka-connector/pom.xml | 12 +
connectors/camel-vm-kafka-connector/pom.xml | 12 +
connectors/camel-weather-kafka-connector/pom.xml | 12 +
.../docs/camel-weather-kafka-sink-connector.adoc | 13 +-
.../docs/camel-weather-kafka-source-connector.adoc | 35 +--
.../weather/CamelWeatherSinkConnectorConfig.java | 44 +--
.../weather/CamelWeatherSourceConnectorConfig.java | 120 +++------
connectors/camel-web3j-kafka-connector/pom.xml | 12 +
.../docs/camel-web3j-kafka-sink-connector.adoc | 36 ++-
.../docs/camel-web3j-kafka-source-connector.adoc | 13 +-
.../web3j/CamelWeb3jSinkConnectorConfig.java | 136 ++++++++++
.../web3j/CamelWeb3jSourceConnectorConfig.java | 44 +++
connectors/camel-webhook-kafka-connector/pom.xml | 12 +
.../docs/camel-webhook-kafka-source-connector.adoc | 7 +-
.../webhook/CamelWebhookSourceConnectorConfig.java | 20 ++
.../camel-websocket-jsr356-kafka-connector/pom.xml | 12 +
connectors/camel-websocket-kafka-connector/pom.xml | 12 +
.../docs/camel-websocket-kafka-sink-connector.adoc | 3 +-
.../camel-websocket-kafka-source-connector.adoc | 3 +-
.../CamelWebsocketSinkConnectorConfig.java | 4 -
.../CamelWebsocketSourceConnectorConfig.java | 4 -
connectors/camel-weka-kafka-connector/pom.xml | 12 +
connectors/camel-wordpress-kafka-connector/pom.xml | 12 +
.../docs/camel-wordpress-kafka-sink-connector.adoc | 10 +-
.../camel-wordpress-kafka-source-connector.adoc | 10 +-
.../CamelWordpressSinkConnectorConfig.java | 32 +++
.../CamelWordpressSourceConnectorConfig.java | 32 +++
connectors/camel-workday-kafka-connector/pom.xml | 12 +
connectors/camel-xchange-kafka-connector/pom.xml | 12 +
connectors/camel-xj-kafka-connector/pom.xml | 12 +
.../camel-xmlsecurity-sign-kafka-connector/pom.xml | 12 +
...amel-xmlsecurity-sign-kafka-sink-connector.adoc | 30 ++-
.../CamelXmlsecuritysignSinkConnectorConfig.java | 112 +++++++-
.../pom.xml | 12 +
...el-xmlsecurity-verify-kafka-sink-connector.adoc | 20 +-
.../CamelXmlsecurityverifySinkConnectorConfig.java | 72 ++++-
connectors/camel-xmpp-kafka-connector/pom.xml | 12 +
connectors/camel-xquery-kafka-connector/pom.xml | 12 +
.../docs/camel-xquery-kafka-source-connector.adoc | 4 +-
.../xquery/CamelXquerySourceConnectorConfig.java | 4 +-
connectors/camel-xslt-kafka-connector/pom.xml | 12 +
.../camel-xslt-saxon-kafka-connector/pom.xml | 12 +
connectors/camel-yammer-kafka-connector/pom.xml | 12 +
.../docs/camel-yammer-kafka-sink-connector.adoc | 11 +-
.../docs/camel-yammer-kafka-source-connector.adoc | 27 +-
.../yammer/CamelYammerSinkConnectorConfig.java | 18 +-
.../yammer/CamelYammerSourceConnectorConfig.java | 52 +++-
connectors/camel-zendesk-kafka-connector/pom.xml | 12 +
.../docs/camel-zendesk-kafka-sink-connector.adoc | 2 +-
.../docs/camel-zendesk-kafka-source-connector.adoc | 6 +-
.../zendesk/CamelZendeskSinkConnectorConfig.java | 8 +-
.../zendesk/CamelZendeskSourceConnectorConfig.java | 12 +-
connectors/camel-zookeeper-kafka-connector/pom.xml | 12 +
.../docs/camel-zookeeper-kafka-sink-connector.adoc | 6 +-
.../camel-zookeeper-kafka-source-connector.adoc | 7 +-
.../CamelZookeeperSinkConnectorConfig.java | 16 ++
.../CamelZookeeperSourceConnectorConfig.java | 20 ++
.../camel-zookeeper-master-kafka-connector/pom.xml | 12 +
...el-zookeeper-master-kafka-source-connector.adoc | 2 +-
.../CamelZookeepermasterSourceConnectorConfig.java | 8 +-
connectors/pom.xml | 19 +-
docs/modules/ROOT/pages/connectors.adoc | 9 +-
.../camel-activemq-kafka-sink-connector.adoc | 29 +-
.../camel-activemq-kafka-source-connector.adoc | 25 +-
.../camel-amqp-kafka-sink-connector.adoc | 29 +-
.../camel-amqp-kafka-source-connector.adoc | 25 +-
.../camel-apns-kafka-source-connector.adoc | 4 +-
.../camel-as2-kafka-source-connector.adoc | 4 +-
.../camel-atom-kafka-source-connector.adoc | 4 +-
.../camel-atomix-map-kafka-sink-connector.adoc | 15 +-
.../camel-atomix-map-kafka-source-connector.adoc | 15 +-
...amel-atomix-messaging-kafka-sink-connector.adoc | 16 +-
...el-atomix-messaging-kafka-source-connector.adoc | 16 +-
...camel-atomix-multimap-kafka-sink-connector.adoc | 15 +-
.../camel-atomix-queue-kafka-sink-connector.adoc | 13 +-
.../camel-atomix-queue-kafka-source-connector.adoc | 13 +-
.../camel-atomix-set-kafka-sink-connector.adoc | 14 +-
.../camel-atomix-set-kafka-source-connector.adoc | 14 +-
.../camel-atomix-value-kafka-sink-connector.adoc | 14 +-
.../camel-atomix-value-kafka-source-connector.adoc | 14 +-
.../camel-avro-kafka-sink-connector.adoc | 8 +-
.../camel-avro-kafka-source-connector.adoc | 8 +-
.../camel-aws-cw-kafka-sink-connector.adoc | 18 +-
.../camel-aws-ddb-kafka-sink-connector.adoc | 18 +-
...camel-aws-ddbstream-kafka-source-connector.adoc | 21 +-
.../camel-aws-ec2-kafka-sink-connector.adoc | 13 +-
.../camel-aws-ecs-kafka-sink-connector.adoc | 11 +-
.../camel-aws-eks-kafka-sink-connector.adoc | 11 +-
.../camel-aws-iam-kafka-sink-connector.adoc | 11 +-
...-aws-kinesis-firehose-kafka-sink-connector.adoc | 14 +-
.../camel-aws-kinesis-kafka-sink-connector.adoc | 14 +-
.../camel-aws-kinesis-kafka-source-connector.adoc | 23 +-
.../camel-aws-kms-kafka-sink-connector.adoc | 11 +-
.../camel-aws-lambda-kafka-sink-connector.adoc | 15 +-
.../camel-aws-mq-kafka-sink-connector.adoc | 11 +-
.../camel-aws-msk-kafka-sink-connector.adoc | 11 +-
.../camel-aws-s3-kafka-sink-connector.adoc | 40 ++-
.../camel-aws-s3-kafka-source-connector.adoc | 41 ++-
.../camel-aws-ses-kafka-sink-connector.adoc | 18 +-
.../camel-aws-sns-kafka-sink-connector.adoc | 23 +-
.../camel-aws-sqs-kafka-sink-connector.adoc | 29 +-
.../camel-aws-sqs-kafka-source-connector.adoc | 55 +++-
.../camel-aws-swf-kafka-sink-connector.adoc | 33 ++-
.../camel-aws-swf-kafka-source-connector.adoc | 36 ++-
.../camel-aws-translate-kafka-sink-connector.adoc | 14 +-
.../camel-aws2-cw-kafka-sink-connector.adoc | 18 +-
.../camel-aws2-ddb-kafka-sink-connector.adoc | 18 +-
...amel-aws2-ddbstream-kafka-source-connector.adoc | 21 +-
.../camel-aws2-ec2-kafka-sink-connector.adoc | 11 +-
.../camel-aws2-ecs-kafka-sink-connector.adoc | 19 +-
.../camel-aws2-eks-kafka-sink-connector.adoc | 19 +-
.../camel-aws2-iam-kafka-sink-connector.adoc | 19 +-
...aws2-kinesis-firehose-kafka-sink-connector.adoc | 49 ++++
.../camel-aws2-kinesis-kafka-sink-connector.adoc | 49 ++++
.../camel-aws2-kinesis-kafka-source-connector.adoc | 41 +--
.../camel-aws2-kms-kafka-sink-connector.adoc | 19 +-
.../camel-aws2-lambda-kafka-sink-connector.adoc | 51 ++++
.../camel-aws2-mq-kafka-sink-connector.adoc | 19 +-
.../camel-aws2-msk-kafka-sink-connector.adoc | 19 +-
.../camel-aws2-s3-kafka-sink-connector.adoc | 75 ++++++
...c => camel-aws2-s3-kafka-source-connector.adoc} | 79 +++---
.../camel-aws2-ses-kafka-sink-connector.adoc | 18 +-
.../camel-aws2-sns-kafka-sink-connector.adoc | 22 +-
.../camel-aws2-sqs-kafka-sink-connector.adoc | 29 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 55 +++-
.../camel-aws2-translate-kafka-sink-connector.adoc | 22 +-
.../camel-azure-blob-kafka-sink-connector.adoc | 21 +-
.../camel-azure-blob-kafka-source-connector.adoc | 15 +-
.../camel-azure-queue-kafka-sink-connector.adoc | 12 +-
.../camel-azure-queue-kafka-source-connector.adoc | 8 +-
.../camel-beanstalk-kafka-source-connector.adoc | 4 +-
.../connectors/camel-box-kafka-sink-connector.adoc | 19 +-
.../camel-box-kafka-source-connector.adoc | 27 +-
.../camel-braintree-kafka-sink-connector.adoc | 5 +-
.../camel-braintree-kafka-source-connector.adoc | 19 +-
.../camel-caffeine-cache-kafka-sink-connector.adoc | 17 +-
...el-caffeine-loadcache-kafka-sink-connector.adoc | 17 +-
.../camel-cometd-kafka-sink-connector.adoc | 2 +-
.../camel-cometd-kafka-source-connector.adoc | 2 +-
.../camel-cometds-kafka-sink-connector.adoc | 2 +-
.../camel-cometds-kafka-source-connector.adoc | 2 +-
.../camel-consul-kafka-sink-connector.adoc | 26 +-
.../camel-consul-kafka-source-connector.adoc | 33 ++-
.../camel-corda-kafka-sink-connector.adoc | 5 +-
.../camel-corda-kafka-source-connector.adoc | 11 +-
.../camel-couchbase-kafka-source-connector.adoc | 4 +-
.../camel-cql-kafka-source-connector.adoc | 4 +-
.../camel-crypto-kafka-sink-connector.adoc | 20 +-
...el-debezium-mongodb-kafka-source-connector.adoc | 45 +++-
...amel-debezium-mysql-kafka-source-connector.adoc | 77 +++++-
...l-debezium-postgres-kafka-source-connector.adoc | 71 ++++-
...-debezium-sqlserver-kafka-source-connector.adoc | 49 +++-
.../camel-disruptor-kafka-sink-connector.adoc | 3 +-
.../camel-disruptor-kafka-source-connector.adoc | 3 +-
.../camel-disruptor-vm-kafka-sink-connector.adoc | 3 +-
.../camel-disruptor-vm-kafka-source-connector.adoc | 3 +-
.../camel-docker-kafka-sink-connector.adoc | 19 +-
.../camel-docker-kafka-source-connector.adoc | 19 +-
.../camel-ehcache-kafka-sink-connector.adoc | 14 +-
.../camel-ehcache-kafka-source-connector.adoc | 15 +-
.../camel-elsql-kafka-sink-connector.adoc | 2 +-
.../camel-elsql-kafka-source-connector.adoc | 4 +-
.../camel-etcd-keys-kafka-sink-connector.adoc | 14 +-
.../camel-etcd-stats-kafka-sink-connector.adoc | 16 +-
.../camel-etcd-stats-kafka-source-connector.adoc | 21 +-
.../camel-etcd-watch-kafka-source-connector.adoc | 15 +-
.../camel-facebook-kafka-sink-connector.adoc | 29 +-
.../camel-facebook-kafka-source-connector.adoc | 29 +-
.../camel-fhir-kafka-sink-connector.adoc | 27 +-
.../camel-fhir-kafka-source-connector.adoc | 39 ++-
.../camel-file-kafka-source-connector.adoc | 4 +-
.../camel-flatpack-kafka-source-connector.adoc | 4 +-
.../camel-ftp-kafka-source-connector.adoc | 10 +-
.../camel-ftps-kafka-source-connector.adoc | 10 +-
.../camel-ganglia-kafka-sink-connector.adoc | 14 +-
...camel-google-calendar-kafka-sink-connector.adoc | 17 +-
...mel-google-calendar-kafka-source-connector.adoc | 21 +-
...gle-calendar-stream-kafka-source-connector.adoc | 17 +-
.../camel-google-drive-kafka-sink-connector.adoc | 14 +-
.../camel-google-drive-kafka-source-connector.adoc | 18 +-
.../camel-google-mail-kafka-sink-connector.adoc | 13 +-
.../camel-google-mail-kafka-source-connector.adoc | 17 +-
...-google-mail-stream-kafka-source-connector.adoc | 15 +-
.../camel-google-pubsub-kafka-sink-connector.adoc | 9 +-
...camel-google-pubsub-kafka-source-connector.adoc | 7 +-
.../camel-google-sheets-kafka-sink-connector.adoc | 13 +-
...camel-google-sheets-kafka-source-connector.adoc | 17 +-
...oogle-sheets-stream-kafka-source-connector.adoc | 19 +-
.../camel-hdfs-kafka-source-connector.adoc | 4 +-
.../camel-hipchat-kafka-source-connector.adoc | 2 +-
.../camel-imap-kafka-sink-connector.adoc | 29 +-
.../camel-imap-kafka-source-connector.adoc | 39 ++-
.../camel-imaps-kafka-sink-connector.adoc | 29 +-
.../camel-imaps-kafka-source-connector.adoc | 39 ++-
.../camel-infinispan-kafka-sink-connector.adoc | 17 +-
.../camel-infinispan-kafka-source-connector.adoc | 21 +-
.../camel-influxdb-kafka-sink-connector.adoc | 3 +-
.../camel-ironmq-kafka-source-connector.adoc | 4 +-
.../camel-jira-kafka-sink-connector.adoc | 10 +-
.../camel-jira-kafka-source-connector.adoc | 10 +-
.../connectors/camel-jms-kafka-sink-connector.adoc | 29 +-
.../camel-jms-kafka-source-connector.adoc | 25 +-
.../camel-jmx-kafka-source-connector.adoc | 6 +-
.../camel-jooq-kafka-sink-connector.adoc | 5 +-
.../camel-jooq-kafka-source-connector.adoc | 8 +-
.../camel-jpa-kafka-source-connector.adoc | 4 +-
.../camel-jt400-kafka-source-connector.adoc | 4 +-
.../camel-kafka-kafka-sink-connector.adoc | 74 +++++-
.../camel-kafka-kafka-source-connector.adoc | 58 +++-
.../camel-lucene-kafka-sink-connector.adoc | 6 +-
.../camel-milo-client-kafka-sink-connector.adoc | 31 ++-
.../camel-milo-client-kafka-source-connector.adoc | 31 ++-
.../camel-milo-server-kafka-sink-connector.adoc | 6 +-
.../camel-milo-server-kafka-source-connector.adoc | 6 +-
.../camel-mina-kafka-sink-connector.adoc | 22 +-
.../camel-mina-kafka-source-connector.adoc | 23 +-
.../camel-mllp-kafka-sink-connector.adoc | 7 +-
.../camel-mllp-kafka-source-connector.adoc | 9 +-
.../camel-mybatis-kafka-source-connector.adoc | 4 +-
.../camel-nagios-kafka-sink-connector.adoc | 6 +-
.../camel-nats-kafka-sink-connector.adoc | 5 +-
.../camel-nats-kafka-source-connector.adoc | 5 +-
.../camel-netty-http-kafka-sink-connector.adoc | 50 +++-
.../camel-netty-http-kafka-source-connector.adoc | 54 +++-
.../camel-netty-kafka-sink-connector.adoc | 52 +++-
.../camel-netty-kafka-source-connector.adoc | 56 +++-
.../connectors/camel-nsq-kafka-sink-connector.adoc | 2 +-
.../camel-nsq-kafka-source-connector.adoc | 2 +-
.../camel-olingo2-kafka-sink-connector.adoc | 18 +-
.../camel-olingo2-kafka-source-connector.adoc | 23 +-
.../camel-olingo4-kafka-sink-connector.adoc | 18 +-
.../camel-olingo4-kafka-source-connector.adoc | 23 +-
.../camel-paho-kafka-sink-connector.adoc | 29 +-
.../camel-paho-kafka-source-connector.adoc | 29 +-
...pg-replication-slot-kafka-source-connector.adoc | 4 +-
...camel-platform-http-kafka-source-connector.adoc | 4 +-
.../camel-pop3-kafka-sink-connector.adoc | 29 +-
.../camel-pop3-kafka-source-connector.adoc | 39 ++-
.../camel-pop3s-kafka-sink-connector.adoc | 29 +-
.../camel-pop3s-kafka-source-connector.adoc | 39 ++-
.../camel-pulsar-kafka-sink-connector.adoc | 19 +-
.../camel-pulsar-kafka-source-connector.adoc | 26 +-
.../camel-quickfix-kafka-sink-connector.adoc | 3 +-
.../camel-quickfix-kafka-source-connector.adoc | 3 +-
.../camel-rabbitmq-kafka-sink-connector.adoc | 6 +-
.../camel-rabbitmq-kafka-source-connector.adoc | 6 +-
...amel-reactive-streams-kafka-sink-connector.adoc | 7 +-
...el-reactive-streams-kafka-source-connector.adoc | 7 +-
.../camel-robotframework-kafka-sink-connector.adoc | 47 +++-
...amel-robotframework-kafka-source-connector.adoc | 51 +++-
.../camel-rss-kafka-source-connector.adoc | 4 +-
.../camel-salesforce-kafka-sink-connector.adoc | 44 ++-
.../camel-salesforce-kafka-source-connector.adoc | 44 ++-
.../camel-scheduler-kafka-source-connector.adoc | 4 +-
.../camel-servicenow-kafka-sink-connector.adoc | 43 ++-
.../camel-sftp-kafka-source-connector.adoc | 10 +-
.../camel-slack-kafka-source-connector.adoc | 4 +-
.../camel-smpp-kafka-sink-connector.adoc | 35 ++-
.../camel-smpp-kafka-source-connector.adoc | 22 +-
.../camel-smpps-kafka-sink-connector.adoc | 35 ++-
.../camel-smpps-kafka-source-connector.adoc | 22 +-
.../camel-smtp-kafka-sink-connector.adoc | 29 +-
.../camel-smtp-kafka-source-connector.adoc | 39 ++-
.../camel-smtps-kafka-sink-connector.adoc | 29 +-
.../camel-smtps-kafka-source-connector.adoc | 39 ++-
.../camel-snmp-kafka-source-connector.adoc | 2 +-
.../camel-splunk-kafka-source-connector.adoc | 4 +-
.../connectors/camel-sql-kafka-sink-connector.adoc | 2 +-
.../camel-sql-kafka-source-connector.adoc | 4 +-
.../connectors/camel-ssh-kafka-sink-connector.adoc | 17 +-
.../camel-ssh-kafka-source-connector.adoc | 20 +-
.../camel-stomp-kafka-sink-connector.adoc | 11 +-
.../camel-stomp-kafka-source-connector.adoc | 11 +-
.../camel-telegram-kafka-source-connector.adoc | 8 +-
.../camel-timer-kafka-source-connector.adoc | 4 +-
.../camel-twilio-kafka-source-connector.adoc | 4 +-
...itter-directmessage-kafka-source-connector.adoc | 12 +-
...amel-twitter-search-kafka-source-connector.adoc | 12 +-
...el-twitter-timeline-kafka-source-connector.adoc | 12 +-
.../camel-undertow-kafka-sink-connector.adoc | 10 +-
.../camel-undertow-kafka-source-connector.adoc | 10 +-
.../camel-weather-kafka-sink-connector.adoc | 13 +-
.../camel-weather-kafka-source-connector.adoc | 35 +--
.../camel-web3j-kafka-sink-connector.adoc | 36 ++-
.../camel-web3j-kafka-source-connector.adoc | 13 +-
.../camel-webhook-kafka-source-connector.adoc | 7 +-
.../camel-websocket-kafka-sink-connector.adoc | 3 +-
.../camel-websocket-kafka-source-connector.adoc | 3 +-
.../camel-wordpress-kafka-sink-connector.adoc | 10 +-
.../camel-wordpress-kafka-source-connector.adoc | 10 +-
...amel-xmlsecurity-sign-kafka-sink-connector.adoc | 30 ++-
...el-xmlsecurity-verify-kafka-sink-connector.adoc | 20 +-
.../camel-xquery-kafka-source-connector.adoc | 4 +-
.../camel-yammer-kafka-sink-connector.adoc | 11 +-
.../camel-yammer-kafka-source-connector.adoc | 27 +-
.../camel-zendesk-kafka-sink-connector.adoc | 2 +-
.../camel-zendesk-kafka-source-connector.adoc | 6 +-
.../camel-zookeeper-kafka-sink-connector.adoc | 6 +-
.../camel-zookeeper-kafka-source-connector.adoc | 7 +-
...el-zookeeper-master-kafka-source-connector.adoc | 2 +-
parent/pom.xml | 2 +-
1107 files changed, 24448 insertions(+), 5140 deletions(-)
copy connectors/{camel-hazelcast-atomicvalue-kafka-connector =>
camel-aws2-kinesis-firehose-kafka-connector}/pom.xml (86%)
rename connectors/{camel-spark-rest-kafka-connector =>
camel-aws2-kinesis-firehose-kafka-connector}/src/main/assembly/package.xml
(100%)
create mode 100644
connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/docs/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
copy
connectors/{camel-atmosphere-websocket-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atmospherewebsocket/CamelAtmospherewebsocketSinkConnector.java
=>
camel-aws2-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesisfirehose/CamelAws2kinesisfirehoseSinkConnector.java}
(84%)
create mode 100644
connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesisfirehose/CamelAws2kinesisfirehoseSinkConnectorConfig.java
copy
connectors/{camel-atmosphere-websocket-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atmospherewebsocket/CamelAtmospherewebsocketSinkTask.java
=>
camel-aws2-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesisfirehose/CamelAws2kinesisfirehoseSinkTask.java}
(87%)
rename connectors/{camel-spark-rest-kafka-connector =>
camel-aws2-kinesis-firehose-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
rename connectors/{camel-spark-rest-kafka-connector =>
camel-aws2-kinesis-firehose-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
copy connectors/{camel-atomix-queue-kafka-connector =>
camel-aws2-kinesis-kafka-connector}/pom.xml (86%)
rename connectors/{camel-paxlogging-kafka-connector =>
camel-aws2-kinesis-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644
connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-sink-connector.adoc
copy
connectors/{camel-aws-kinesis-kafka-connector/src/main/docs/camel-aws-kinesis-kafka-source-connector.adoc
=>
camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-source-connector.adoc}
(64%)
copy
connectors/{camel-atomix-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atomixqueue/CamelAtomixqueueSinkConnector.java
=>
camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSinkConnector.java}
(85%)
create mode 100644
connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSinkConnectorConfig.java
copy
connectors/{camel-ahc-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/ahc/CamelAhcSinkTask.java
=>
camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSinkTask.java}
(88%)
copy
connectors/{camel-atomix-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atomixqueue/CamelAtomixqueueSourceConnector.java
=>
camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSourceConnector.java}
(84%)
create mode 100644
connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSourceConnectorConfig.java
copy
connectors/{camel-atomix-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atomixqueue/CamelAtomixqueueSourceTask.java
=>
camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSourceTask.java}
(87%)
rename connectors/{camel-paxlogging-kafka-connector =>
camel-aws2-kinesis-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
rename connectors/{camel-paxlogging-kafka-connector =>
camel-aws2-kinesis-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
copy connectors/{camel-aws-kinesis-kafka-connector =>
camel-aws2-lambda-kafka-connector}/pom.xml (86%)
copy connectors/{camel-zookeeper-master-kafka-connector =>
camel-aws2-lambda-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644
connectors/camel-aws2-lambda-kafka-connector/src/main/docs/camel-aws2-lambda-kafka-sink-connector.adoc
copy
connectors/{camel-aws-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesis/CamelAwskinesisSinkConnector.java
=>
camel-aws2-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2lambda/CamelAws2lambdaSinkConnector.java}
(85%)
create mode 100644
connectors/camel-aws2-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2lambda/CamelAws2lambdaSinkConnectorConfig.java
copy
connectors/{camel-ahc-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/ahc/CamelAhcSinkTask.java
=>
camel-aws2-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2lambda/CamelAws2lambdaSinkTask.java}
(88%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-aws2-lambda-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-aws2-lambda-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
copy connectors/{camel-ahc-wss-kafka-connector =>
camel-aws2-s3-kafka-connector}/pom.xml (86%)
copy connectors/{camel-zookeeper-master-kafka-connector =>
camel-aws2-s3-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644
connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
copy
docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc =>
connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
(59%)
copy
connectors/{camel-ahc-wss-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/ahcwss/CamelAhcwssSinkConnector.java
=>
camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnector.java}
(85%)
create mode 100644
connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
copy
connectors/{camel-ahc-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/ahc/CamelAhcSinkTask.java
=>
camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkTask.java}
(89%)
copy
connectors/{camel-aws-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqs/CamelAwssqsSourceConnector.java
=>
camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnector.java}
(85%)
create mode 100644
connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
copy
connectors/{camel-ahc-ws-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/ahcws/CamelAhcwsSourceTask.java
=>
camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceTask.java}
(88%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-aws2-s3-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-aws2-s3-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
delete mode 100644 connectors/camel-eventadmin-kafka-connector/pom.xml
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/docs/camel-eventadmin-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/docs/camel-eventadmin-kafka-source-connector.adoc
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/eventadmin/CamelEventadminSinkConnector.java
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/eventadmin/CamelEventadminSinkConnectorConfig.java
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/eventadmin/CamelEventadminSinkTask.java
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/eventadmin/CamelEventadminSourceConnector.java
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/eventadmin/CamelEventadminSourceConnectorConfig.java
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/eventadmin/CamelEventadminSourceTask.java
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-eventadmin-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-paxlogging-kafka-connector/pom.xml
delete mode 100644
connectors/camel-paxlogging-kafka-connector/src/main/docs/camel-paxlogging-kafka-source-connector.adoc
delete mode 100644
connectors/camel-paxlogging-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/paxlogging/CamelPaxloggingSourceConnector.java
delete mode 100644
connectors/camel-paxlogging-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/paxlogging/CamelPaxloggingSourceConnectorConfig.java
delete mode 100644
connectors/camel-paxlogging-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/paxlogging/CamelPaxloggingSourceTask.java
delete mode 100644 connectors/camel-spark-rest-kafka-connector/pom.xml
delete mode 100644
connectors/camel-spark-rest-kafka-connector/src/main/docs/camel-spark-rest-kafka-source-connector.adoc
delete mode 100644
connectors/camel-spark-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sparkrest/CamelSparkrestSourceConnector.java
delete mode 100644
connectors/camel-spark-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sparkrest/CamelSparkrestSourceConnectorConfig.java
delete mode 100644
connectors/camel-spark-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sparkrest/CamelSparkrestSourceTask.java
create mode 100644
docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
create mode 100644
docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-sink-connector.adoc
copy
connectors/camel-aws-kinesis-kafka-connector/src/main/docs/camel-aws-kinesis-kafka-source-connector.adoc
=>
docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-source-connector.adoc
(64%)
create mode 100644
docs/modules/ROOT/pages/connectors/camel-aws2-lambda-kafka-sink-connector.adoc
create mode 100644
docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
copy
docs/modules/ROOT/pages/connectors/{camel-aws-s3-kafka-source-connector.adoc =>
camel-aws2-s3-kafka-source-connector.adoc} (59%)
