This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
discard 5e3ae7d [create-pull-request] automated change omit 769287c [create-pull-request] automated change omit 3198001 [create-pull-request] automated change omit fcb85ca Fixed catalog test with JDK11 omit 41ed0d6 Regen omit 669d726 Fixed Test and regen omit 099f56e Regen and fixed compilation omit 67302bd Fixed CamelKafkaConnectorCatalogTest omit 3810a62 Camel-kafka-connector-catalog: Avoid to check for number of options on camel-master omit bff8ad6 Updated AWS test services according to interface changes from camel 3.7 omit 7cbd010 Regen omit 2ac661c File language and core languages in general are not working omit cf42b29 Camel-Master: Fix catalog test omit 610da53 Fix couchbase catalog test omit 48707ef Fixed incorrect formatting of Bucket URL in Couchbase tests omit 620bb58 Aligned camel-master tests with fix omit fc53d5a Adjust the emdedded Kafka service to the updated interface from Camel 3.7 omit 8271de5 Catalog tests fixed omit 377525b Camel-Master: Fixed catalog test for aws2-sns omit 5c5be96 [create-pull-request] automated change omit 72b7670 [create-pull-request] automated change omit 700047d Temporarily disable a test affected by CAMEL-15789 omit d4a5131 Point to 3.7.0-SNAPSHOT add 2303669 Updated CHANGELOG.md add 2f48ec1 Remove an unused annotation that (apparently) slows down the tests a little bit add 0f94c14 Do not nullify the cluster reference on the embedded kafka service. add e84b2c2 Rework the AWS v1 tests to fix tests performance issues add d83202f Rework the AWS v2 tests to fix tests performance issues add b487897 Updated CHANGELOG.md add 36954d3 Updated CHANGELOG.md add d74f38e Added dataformat archetype documentation add 9733562 Added dataformat archetype to TOC add 21a0cb5 Added dataformat connector docs to nav add bb658c9 Set JMS clients scope runtime to include required dependencies in the package add 2c0c725 Updated CHANGELOG.md add eef47b8 Added docs for Apicurio archetype add a653794 Added Apicurio archetype docs to index add 4f35962 Added Apicurio archetype docs to nav add 206b51e Added Camel-SQL Kafka Connector integration tests add e6b61f2 IT Test SQL: Fixed CS add efa2baa Added SQL IT Test to Tests POM add 282b940 Removed wrong connectors coming from camel-master add cd9356d Regen add b120dab Support Poll timeout and key cache size as option for kafka idempotent repository add 3d9e8ee Support Poll timeout and key cache size as option for kafka idempotent repository add 76157f3 Updated CHANGELOG.md add 6e0e2ad chore: documentation regen for 0.6.1 add 5d5fa8d Updated CHANGELOG.md add d437eac Updated CHANGELOG.md add 44b53c2 Add a removeHeaders option on both source and sink add d2cbe95 Fixed CS add 8a78976 Updated CHANGELOG.md add dc31b55 Updated CHANGELOG.md add b64e2b6 Updated CHANGELOG.md add 9395995 Added 0.6.1 release to compatibility matrix. add 77b35cf fix #754 : create binary ditribution. add fbbc3b8 Updated CHANGELOG.md add 373f5bf Fix example CamelAmqpSourceConnector using sink instead of source property #767 add e607124 Updated CHANGELOG.md new 81dfc3e Point to 3.7.0-SNAPSHOT new 73a67b0 Temporarily disable a test affected by CAMEL-15789 new c7ba462 Camel-Master: Fixed catalog test for aws2-sns new bf14d33 Catalog tests fixed new 86ce43c Adjust the emdedded Kafka service to the updated interface from Camel 3.7 new 6ff96a1 Aligned camel-master tests with fix new 8bb9654 Fixed incorrect formatting of Bucket URL in Couchbase tests new 81c83e3 Fix couchbase catalog test new 7a67121 Camel-Master: Fix catalog test new b695950 File language and core languages in general are not working new d5c3560 Updated AWS test services according to interface changes from camel 3.7 new 1a414e2 Camel-kafka-connector-catalog: Avoid to check for number of options on camel-master new ec041b9 Fixed CamelKafkaConnectorCatalogTest new cc5fb83 Fixed build new f91191c Fixed build and regen new a68e9b6 Fixed build and regen new 69b49dc Full Rebuild and regen This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (5e3ae7d) \ N -- N -- N refs/heads/camel-master (69b49dc) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 17 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: CHANGELOG.md | 107 +- .../resources/connectors/camel-atlasmap-sink.json | 2 +- .../resources/connectors/camel-aws2-sns-sink.json | 4 +- .../resources/connectors/camel-github-sink.json | 30 +- .../resources/connectors/camel-github-source.json | 30 +- .../camel-kubernetes-custom-resources-sink.json | 2 +- .../camel-kubernetes-custom-resources-source.json | 2 +- .../connectors/camel-vertx-kafka-sink.json | 971 ++++++++++++++++++ .../connectors/camel-vertx-kafka-source.json | 1073 ++++++++++++++++++++ .../resources/descriptors/connectors.properties | 2 + .../generated/resources/camel-atlasmap-sink.json | 2 +- .../docs/camel-atlasmap-kafka-sink-connector.adoc | 4 + .../generated/resources/camel-aws2-sns-sink.json | 4 +- .../docs/camel-aws2-sns-kafka-sink-connector.adoc | 4 +- .../aws2sns/CamelAws2snsSinkConnectorConfig.java | 4 +- .../pom.xml | 4 - .../src/generated/resources/camel-github-sink.json | 30 +- .../generated/resources/camel-github-source.json | 30 +- .../docs/camel-github-kafka-sink-connector.adoc | 7 +- .../docs/camel-github-kafka-source-connector.adoc | 7 +- .../github/CamelGithubSinkConnectorConfig.java | 20 +- .../github/CamelGithubSourceConnectorConfig.java | 20 +- ...mel-kafka-connector-fix-dependencies.properties | 7 +- .../camel-kubernetes-custom-resources-sink.json | 2 +- .../camel-kubernetes-custom-resources-source.json | 2 +- ...etes-custom-resources-kafka-sink-connector.adoc | 4 + ...es-custom-resources-kafka-source-connector.adoc | 4 + connectors/camel-sjms2-kafka-connector/pom.xml | 2 + .../pom.xml | 12 +- .../descriptors/connector-sink.properties | 1 + .../descriptors/connector-source.properties | 1 + .../resources/camel-vertx-kafka-sink.json | 971 ++++++++++++++++++ .../resources/camel-vertx-kafka-source.json | 1073 ++++++++++++++++++++ .../src/main/assembly/package.xml | 0 .../camel-vertx-kafka-kafka-sink-connector.adoc | 197 ++++ .../camel-vertx-kafka-kafka-source-connector.adoc | 213 ++++ .../CamelVertxkafkaSinkConnector.properties | 22 +- .../CamelVertxkafkaSourceConnector.properties | 22 +- .../vertxkafka/CamelVertxkafkaSinkConnector.java | 35 + .../CamelVertxkafkaSinkConnectorConfig.java | 620 +++++++++++ .../vertxkafka/CamelVertxkafkaSinkTask.java | 39 + .../vertxkafka/CamelVertxkafkaSourceConnector.java | 35 + .../CamelVertxkafkaSourceConnectorConfig.java | 684 +++++++++++++ .../vertxkafka/CamelVertxkafkaSourceTask.java | 39 + .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 connectors/pom.xml | 3 +- .../camel/kafkaconnector/CamelConnectorConfig.java | 12 + .../kafkaconnector/CamelSinkConnectorConfig.java | 5 +- .../apache/camel/kafkaconnector/CamelSinkTask.java | 6 + .../kafkaconnector/CamelSourceConnectorConfig.java | 5 +- .../camel/kafkaconnector/CamelSourceTask.java | 6 + .../utils/CamelKafkaConnectMain.java | 60 +- .../camel/kafkaconnector/CamelSinkTaskTest.java | 49 + .../camel/kafkaconnector/CamelSourceTaskTest.java | 32 + distribution/pom.xml | 15 +- .../src/main/assemblies/binary-release.xml | 48 + docs/modules/ROOT/nav.adoc | 2 + .../ROOT/pages/archetype-apicurio-connector.adoc | 189 ++++ .../ROOT/pages/archetype-dataformat-connector.adoc | 184 ++++ .../ROOT/pages/camel-compatibility-matrix.adoc | 1 + docs/modules/ROOT/pages/connectors.adoc | 699 ++++++------- .../camel-atlasmap-kafka-sink-connector.adoc | 4 + .../camel-aws2-sns-kafka-sink-connector.adoc | 4 +- .../camel-github-kafka-sink-connector.adoc | 7 +- .../camel-github-kafka-source-connector.adoc | 7 +- ...etes-custom-resources-kafka-sink-connector.adoc | 4 + ...es-custom-resources-kafka-source-connector.adoc | 4 + .../camel-vertx-kafka-kafka-sink-connector.adoc | 197 ++++ .../camel-vertx-kafka-kafka-source-connector.adoc | 213 ++++ docs/modules/ROOT/pages/index.adoc | 2 + docs/modules/ROOT/pages/troubleshooting.adoc | 8 +- docs/modules/ROOT/pages/try-it-out-locally.adoc | 15 +- examples/CamelAmqpSourceConnector.properties | 4 +- .../source/CamelSourceAWSKinesisITCase.java | 10 +- .../aws/v1/s3/source/CamelSourceAWSS3ITCase.java | 7 +- .../aws/v1/sns/sink/CamelSinkAWSSNSITCase.java | 8 +- .../aws/v1/sqs/sink/CamelSinkAWSSQSITCase.java | 8 +- .../aws/v1/sqs/source/CamelSourceAWSSQSITCase.java | 9 +- .../source/CamelSourceAWSKinesisITCase.java | 8 +- .../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 6 +- .../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 9 +- .../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 6 +- .../kafkaconnector/common/AbstractKafkaTest.java | 2 - .../services/kafka/EmbeddedKafkaService.java | 1 - tests/itests-sql/pom.xml | 60 ++ .../kafkaconnector/sql/client/DatabaseClient.java | 70 ++ .../sql/services/SQLLocalContainerService.java | 55 + .../sql/services/SQLRemoteService.java | 41 + .../kafkaconnector/sql/services/SQLService.java | 46 + .../sql/services/SQLServiceFactory.java | 43 + .../sql/services/TestDataSource.java | 41 + .../sql/sink/CamelSinkSQLITCase.java | 147 +++ .../sql/sink/CamelSqlPropertyFactory.java | 39 + .../sql/source/CamelSourceSQLITCase.java | 84 ++ .../sql/source/CamelSqlPropertyFactory.java | 39 + tests/itests-sql/src/test/resources/schema.sql | 24 + tests/pom.xml | 1 + ...mel-kafka-connector-fix-dependencies.properties | 2 +- 99 files changed, 8289 insertions(+), 606 deletions(-) create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-vertx-kafka-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-vertx-kafka-source.json copy connectors/{camel-elasticsearch-rest-kafka-connector => camel-vertx-kafka-kafka-connector}/pom.xml (92%) create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/generated/resources/camel-vertx-kafka-sink.json create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/generated/resources/camel-vertx-kafka-source.json copy connectors/{camel-zookeeper-master-kafka-connector => camel-vertx-kafka-kafka-connector}/src/main/assembly/package.xml (100%) create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/docs/camel-vertx-kafka-kafka-sink-connector.adoc create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/docs/camel-vertx-kafka-kafka-source-connector.adoc copy tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-fix-dependencies.properties => connectors/camel-vertx-kafka-kafka-connector/src/main/docs/examples/CamelVertxkafkaSinkConnector.properties (58%) copy tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-fix-dependencies.properties => connectors/camel-vertx-kafka-kafka-connector/src/main/docs/examples/CamelVertxkafkaSourceConnector.properties (58%) create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxkafka/CamelVertxkafkaSinkConnector.java create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxkafka/CamelVertxkafkaSinkConnectorConfig.java create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxkafka/CamelVertxkafkaSinkTask.java create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxkafka/CamelVertxkafkaSourceConnector.java create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxkafka/CamelVertxkafkaSourceConnectorConfig.java create mode 100644 connectors/camel-vertx-kafka-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxkafka/CamelVertxkafkaSourceTask.java copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-vertx-kafka-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%) copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-vertx-kafka-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 distribution/src/main/assemblies/binary-release.xml create mode 100644 docs/modules/ROOT/pages/archetype-apicurio-connector.adoc create mode 100644 docs/modules/ROOT/pages/archetype-dataformat-connector.adoc create mode 100644 docs/modules/ROOT/pages/connectors/camel-vertx-kafka-kafka-sink-connector.adoc create mode 100644 docs/modules/ROOT/pages/connectors/camel-vertx-kafka-kafka-source-connector.adoc create mode 100644 tests/itests-sql/pom.xml create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/client/DatabaseClient.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/services/SQLLocalContainerService.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/services/SQLRemoteService.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/services/SQLService.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/services/SQLServiceFactory.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/services/TestDataSource.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSqlPropertyFactory.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/source/CamelSourceSQLITCase.java create mode 100644 tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/source/CamelSqlPropertyFactory.java create mode 100644 tests/itests-sql/src/test/resources/schema.sql