This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch automatic-periodic-sync in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
omit 5f0e350 [create-pull-request] automated change add 4753785 Updated CHANGELOG.md add 80c22fe Decouple the JMS client from the service to simplify using the test infra from Camel add e85aa5c Do initialize the container at the correct callback add 4499b54 Updated CHANGELOG.md add 8d23aec [create-pull-request] automated change add 236d34f Point to 3.7.0-SNAPSHOT add c8e403e Include the common infra as required test dependency add 1977049 Temporarily disable a test affected by CAMEL-15789 add a594731 [create-pull-request] automated change 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 (5f0e350) \ N -- N -- N refs/heads/automatic-periodic-sync (a594731) 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. No new revisions were added by this update. Summary of changes: CHANGELOG.md | 11 ++ .../resources/connectors/camel-aws2-sqs-sink.json | 14 ++ .../connectors/camel-aws2-sqs-source.json | 14 ++ .../connectors/camel-azure-storage-blob-sink.json | 12 ++ .../camel-azure-storage-blob-source.json | 12 ++ .../resources/connectors/camel-couchbase-sink.json | 4 +- .../connectors/camel-couchbase-source.json | 4 +- .../resources/connectors/camel-git-sink.json | 40 ++--- .../resources/connectors/camel-git-source.json | 30 ---- .../resources/connectors/camel-grpc-sink.json | 7 + .../resources/connectors/camel-grpc-source.json | 14 ++ .../resources/connectors/camel-kafka-sink.json | 24 +-- .../resources/connectors/camel-kafka-source.json | 24 +-- .../camel-kubernetes-deployments-source.json | 30 ++++ .../connectors/camel-kubernetes-hpa-source.json | 30 ++++ .../connectors/camel-kubernetes-job-source.json | 30 ++++ .../camel-kubernetes-namespaces-source.json | 30 ++++ .../connectors/camel-kubernetes-nodes-source.json | 30 ++++ .../connectors/camel-kubernetes-pods-source.json | 30 ++++ ...-kubernetes-replication-controllers-source.json | 30 ++++ .../camel-kubernetes-services-source.json | 30 ++++ .../resources/connectors/camel-pulsar-source.json | 14 ++ .../connectors/camel-vertx-websocket-sink.json | 6 + .../resources/descriptors/connectors.properties | 3 + connectors/camel-atlasmap-kafka-connector/pom.xml | 135 +++++++++++++++ .../descriptors/connector-sink.properties | 1 + .../generated/resources/camel-atlasmap-sink.json | 99 +++++++++++ .../src/main/assembly/package.xml | 0 .../docs/camel-atlasmap-kafka-sink-connector.adoc | 66 +++++++ .../CamelAtlasmapSinkConnector.properties} | 10 +- .../atlasmap/CamelAtlasmapSinkConnector.java | 35 ++++ .../atlasmap/CamelAtlasmapSinkConnectorConfig.java | 96 +++++++++++ .../atlasmap/CamelAtlasmapSinkTask.java | 39 +++++ .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../generated/resources/camel-aws2-sqs-sink.json | 14 ++ .../generated/resources/camel-aws2-sqs-source.json | 14 ++ .../docs/camel-aws2-sqs-kafka-sink-connector.adoc | 4 +- .../camel-aws2-sqs-kafka-source-connector.adoc | 4 +- .../aws2sqs/CamelAws2sqsSinkConnectorConfig.java | 8 + .../aws2sqs/CamelAws2sqsSourceConnectorConfig.java | 8 + .../resources/camel-azure-storage-blob-sink.json | 12 ++ .../resources/camel-azure-storage-blob-source.json | 12 ++ ...el-azure-storage-blob-kafka-sink-connector.adoc | 4 +- ...-azure-storage-blob-kafka-source-connector.adoc | 4 +- .../CamelAzurestorageblobSinkConnectorConfig.java | 8 + ...CamelAzurestorageblobSourceConnectorConfig.java | 8 + .../generated/resources/camel-couchbase-sink.json | 4 +- .../resources/camel-couchbase-source.json | 4 +- .../docs/camel-couchbase-kafka-sink-connector.adoc | 2 +- .../camel-couchbase-kafka-source-connector.adoc | 2 +- .../CamelCouchbaseSinkConnector.properties | 2 + .../CamelCouchbaseSourceConnector.properties | 2 + .../CamelCouchbaseSinkConnectorConfig.java | 2 +- .../CamelCouchbaseSourceConnectorConfig.java | 2 +- .../src/generated/resources/camel-git-sink.json | 40 ++--- .../src/generated/resources/camel-git-source.json | 30 ---- .../main/docs/camel-git-kafka-sink-connector.adoc | 6 +- .../docs/camel-git-kafka-source-connector.adoc | 7 +- .../git/CamelGitSinkConnectorConfig.java | 24 +-- .../git/CamelGitSourceConnectorConfig.java | 20 --- .../src/generated/resources/camel-grpc-sink.json | 7 + .../src/generated/resources/camel-grpc-source.json | 14 ++ .../main/docs/camel-grpc-kafka-sink-connector.adoc | 3 +- .../docs/camel-grpc-kafka-source-connector.adoc | 4 +- .../grpc/CamelGrpcSinkConnectorConfig.java | 4 + .../grpc/CamelGrpcSourceConnectorConfig.java | 8 + .../src/generated/resources/camel-kafka-sink.json | 24 +-- .../generated/resources/camel-kafka-source.json | 24 +-- .../docs/camel-kafka-kafka-sink-connector.adoc | 12 +- .../docs/camel-kafka-kafka-source-connector.adoc | 4 +- .../kafka/CamelKafkaSinkConnectorConfig.java | 48 +++--- .../kafka/CamelKafkaSourceConnectorConfig.java | 16 +- .../pom.xml | 135 +++++++++++++++ .../descriptors/connector-sink.properties | 1 + .../descriptors/connector-source.properties | 1 + .../camel-kubernetes-custom-resources-sink.json | 163 +++++++++--------- .../camel-kubernetes-custom-resources-source.json | 48 +++++- .../src/main/assembly/package.xml | 0 ...etes-custom-resources-kafka-sink-connector.adoc | 78 +++++++++ ...s-custom-resources-kafka-source-connector.adoc} | 31 ++-- ...ernetescustomresourcesSinkConnector.properties} | 10 +- ...netescustomresourcesSourceConnector.properties} | 10 +- ...amelKubernetescustomresourcesSinkConnector.java | 37 ++++ ...bernetescustomresourcesSinkConnectorConfig.java | 145 ++++++++++++++++ .../CamelKubernetescustomresourcesSinkTask.java | 39 +++++ ...elKubernetescustomresourcesSourceConnector.java | 37 ++++ ...rnetescustomresourcesSourceConnectorConfig.java | 189 +++++++++++++++++++++ .../CamelKubernetescustomresourcesSourceTask.java | 39 +++++ .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../camel-kubernetes-deployments-source.json | 30 ++++ ...ernetes-deployments-kafka-source-connector.adoc | 7 +- ...KubernetesdeploymentsSourceConnectorConfig.java | 20 +++ .../resources/camel-kubernetes-hpa-source.json | 30 ++++ ...amel-kubernetes-hpa-kafka-source-connector.adoc | 7 +- .../CamelKuberneteshpaSourceConnectorConfig.java | 20 +++ .../resources/camel-kubernetes-job-source.json | 30 ++++ ...amel-kubernetes-job-kafka-source-connector.adoc | 7 +- .../CamelKubernetesjobSourceConnectorConfig.java | 20 +++ .../camel-kubernetes-namespaces-source.json | 30 ++++ ...bernetes-namespaces-kafka-source-connector.adoc | 7 +- ...lKubernetesnamespacesSourceConnectorConfig.java | 20 +++ .../resources/camel-kubernetes-nodes-source.json | 30 ++++ ...el-kubernetes-nodes-kafka-source-connector.adoc | 7 +- .../CamelKubernetesnodesSourceConnectorConfig.java | 20 +++ .../resources/camel-kubernetes-pods-source.json | 30 ++++ ...mel-kubernetes-pods-kafka-source-connector.adoc | 7 +- .../CamelKubernetespodsSourceConnectorConfig.java | 20 +++ ...-kubernetes-replication-controllers-source.json | 30 ++++ ...ication-controllers-kafka-source-connector.adoc | 7 +- ...eplicationcontrollersSourceConnectorConfig.java | 20 +++ .../camel-kubernetes-services-source.json | 30 ++++ ...kubernetes-services-kafka-source-connector.adoc | 7 +- ...melKubernetesservicesSourceConnectorConfig.java | 20 +++ .../generated/resources/camel-pulsar-source.json | 14 ++ .../docs/camel-pulsar-kafka-source-connector.adoc | 4 +- .../pulsar/CamelPulsarSourceConnectorConfig.java | 8 + .../resources/camel-vertx-websocket-sink.json | 6 + ...camel-vertx-websocket-kafka-sink-connector.adoc | 3 +- .../CamelVertxwebsocketSinkConnectorConfig.java | 4 + connectors/pom.xml | 2 + docs/modules/ROOT/pages/connectors.adoc | 4 +- .../camel-atlasmap-kafka-sink-connector.adoc | 66 +++++++ .../camel-aws2-sqs-kafka-sink-connector.adoc | 4 +- .../camel-aws2-sqs-kafka-source-connector.adoc | 4 +- ...el-azure-storage-blob-kafka-sink-connector.adoc | 4 +- ...-azure-storage-blob-kafka-source-connector.adoc | 4 +- .../camel-couchbase-kafka-sink-connector.adoc | 2 +- .../camel-couchbase-kafka-source-connector.adoc | 2 +- .../connectors/camel-git-kafka-sink-connector.adoc | 6 +- .../camel-git-kafka-source-connector.adoc | 7 +- .../camel-grpc-kafka-sink-connector.adoc | 3 +- .../camel-grpc-kafka-source-connector.adoc | 4 +- .../camel-kafka-kafka-sink-connector.adoc | 12 +- .../camel-kafka-kafka-source-connector.adoc | 4 +- ...etes-custom-resources-kafka-sink-connector.adoc | 78 +++++++++ ...es-custom-resources-kafka-source-connector.adoc | 31 ++-- ...ernetes-deployments-kafka-source-connector.adoc | 7 +- ...amel-kubernetes-hpa-kafka-source-connector.adoc | 7 +- ...amel-kubernetes-job-kafka-source-connector.adoc | 7 +- ...bernetes-namespaces-kafka-source-connector.adoc | 7 +- ...el-kubernetes-nodes-kafka-source-connector.adoc | 7 +- ...mel-kubernetes-pods-kafka-source-connector.adoc | 7 +- ...ication-controllers-kafka-source-connector.adoc | 7 +- ...kubernetes-services-kafka-source-connector.adoc | 7 +- .../camel-pulsar-kafka-source-connector.adoc | 4 +- ...camel-vertx-websocket-kafka-sink-connector.adoc | 3 +- parent/pom.xml | 2 +- pom.xml | 2 +- .../couchbase/sink/CamelSinkCouchbaseITCase.java | 1 + tests/itests-parent/pom.xml | 8 + .../kafkaconnector/sjms2/clients/JMSClient.java | 45 +++++ .../sjms2/services/ArtemisContainer.java | 6 - .../sjms2/services/ContainerLocalService.java | 10 +- .../sjms2/services/JMSContainer.java | 7 - .../kafkaconnector/sjms2/services/JMSService.java | 7 - .../services/QpidDispatchRouterContainer.java | 6 - .../sjms2/services/RemoteJMSService.java | 12 -- .../sjms2/sink/CamelSinkJMSITCase.java | 2 +- .../sjms2/source/CamelSourceJMSITCase.java | 2 +- .../source/CamelSourceJMSWithAggregation.java | 2 +- 162 files changed, 2767 insertions(+), 472 deletions(-) create mode 100644 connectors/camel-atlasmap-kafka-connector/pom.xml create mode 100644 connectors/camel-atlasmap-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-atlasmap-kafka-connector/src/generated/resources/camel-atlasmap-sink.json copy connectors/{camel-zookeeper-master-kafka-connector => camel-atlasmap-kafka-connector}/src/main/assembly/package.xml (100%) create mode 100644 connectors/camel-atlasmap-kafka-connector/src/main/docs/camel-atlasmap-kafka-sink-connector.adoc copy connectors/{camel-couchbase-kafka-connector/src/main/docs/examples/CamelCouchbaseSinkConnector.properties => camel-atlasmap-kafka-connector/src/main/docs/examples/CamelAtlasmapSinkConnector.properties} (72%) create mode 100644 connectors/camel-atlasmap-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atlasmap/CamelAtlasmapSinkConnector.java create mode 100644 connectors/camel-atlasmap-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atlasmap/CamelAtlasmapSinkConnectorConfig.java create mode 100644 connectors/camel-atlasmap-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atlasmap/CamelAtlasmapSinkTask.java copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-atlasmap-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%) copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-atlasmap-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/pom.xml create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/generated/descriptors/connector-source.properties copy camel-kafka-connector-catalog/src/generated/resources/connectors/camel-couchbase-sink.json => connectors/camel-kubernetes-custom-resources-kafka-connector/src/generated/resources/camel-kubernetes-custom-resources-sink.json (51%) copy camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kubernetes-deployments-source.json => connectors/camel-kubernetes-custom-resources-kafka-connector/src/generated/resources/camel-kubernetes-custom-resources-source.json (81%) copy connectors/{camel-zookeeper-master-kafka-connector => camel-kubernetes-custom-resources-kafka-connector}/src/main/assembly/package.xml (100%) create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/main/docs/camel-kubernetes-custom-resources-kafka-sink-connector.adoc copy connectors/{camel-kubernetes-pods-kafka-connector/src/main/docs/camel-kubernetes-pods-kafka-source-connector.adoc => camel-kubernetes-custom-resources-kafka-connector/src/main/docs/camel-kubernetes-custom-resources-kafka-source-connector.adoc} (66%) copy connectors/{camel-couchbase-kafka-connector/src/main/docs/examples/CamelCouchbaseSinkConnector.properties => camel-kubernetes-custom-resources-kafka-connector/src/main/docs/examples/CamelKubernetescustomresourcesSinkConnector.properties} (85%) copy connectors/{camel-couchbase-kafka-connector/src/main/docs/examples/CamelCouchbaseSourceConnector.properties => camel-kubernetes-custom-resources-kafka-connector/src/main/docs/examples/CamelKubernetescustomresourcesSourceConnector.properties} (85%) create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kubernetescustomresources/CamelKubernetescustomresourcesSinkConnector.java create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kubernetescustomresources/CamelKubernetescustomresourcesSinkConnectorConfig.java create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kubernetescustomresources/CamelKubernetescustomresourcesSinkTask.java create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kubernetescustomresources/CamelKubernetescustomresourcesSourceConnector.java create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kubernetescustomresources/CamelKubernetescustomresourcesSourceConnectorConfig.java create mode 100644 connectors/camel-kubernetes-custom-resources-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kubernetescustomresources/CamelKubernetescustomresourcesSourceTask.java copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-kubernetes-custom-resources-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%) copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-kubernetes-custom-resources-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 docs/modules/ROOT/pages/connectors/camel-atlasmap-kafka-sink-connector.adoc create mode 100644 docs/modules/ROOT/pages/connectors/camel-kubernetes-custom-resources-kafka-sink-connector.adoc copy connectors/camel-kubernetes-pods-kafka-connector/src/main/docs/camel-kubernetes-pods-kafka-source-connector.adoc => docs/modules/ROOT/pages/connectors/camel-kubernetes-custom-resources-kafka-source-connector.adoc (66%)