This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 9cb3266625c9b75c177992129dbc52686b8c3620 Merge: 1a65e00 3a7cfe1 Author: Andrea Tarocchi <andrea.taroc...@gmail.com> AuthorDate: Mon May 11 14:53:02 2020 +0200 Merge pull request #206 from apache/camel-3.2.0 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} | 10 +- .../CamelAws2kinesisSinkConnectorConfig.java | 128 +++++++++ .../aws2kinesis/CamelAws2kinesisSinkTask.java} | 14 +- .../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 ++++++ .../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 --------- .../camel-eventadmin-kafka-sink-connector.adoc | 34 --- .../camel-eventadmin-kafka-source-connector.adoc | 36 --- .../CamelEventadminSinkConnectorConfig.java | 76 ------ .../CamelEventadminSourceConnectorConfig.java | 84 ------ 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 --- .../CamelPaxloggingSourceConnectorConfig.java | 80 ------ 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 ---- .../CamelSparkrestSourceConnectorConfig.java | 152 ----------- 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 ++++++ .../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 +- 1096 files changed, 24452 insertions(+), 4577 deletions(-)