[camel-quarkus] branch master updated: Fix #1895 to remove registerNarayanaReflectiveClass
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git The following commit(s) were added to refs/heads/master by this push: new 7d603f9 Fix #1895 to remove registerNarayanaReflectiveClass 7d603f9 is described below commit 7d603f9716683eab222bf0314e7e420a9c9e2b08 Author: Amos Feng AuthorDate: Mon Jan 25 11:18:38 2021 +0800 Fix #1895 to remove registerNarayanaReflectiveClass --- .../camel/quarkus/component/jta/deployment/JtaProcessor.java | 7 --- 1 file changed, 7 deletions(-) diff --git a/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java b/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java index 2a6f389..5f674c7 100644 --- a/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java +++ b/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java @@ -16,7 +16,6 @@ */ package org.apache.camel.quarkus.component.jta.deployment; -import com.arjuna.ats.internal.arjuna.utils.SocketProcessId; import io.quarkus.arc.deployment.AdditionalBeanBuildItem; import io.quarkus.deployment.Capabilities; import io.quarkus.deployment.Capability; @@ -60,10 +59,4 @@ class JtaProcessor { IllegalStateException.class.getName())); } } - -@BuildStep //TODO workaround for https://github.com/apache/camel-quarkus/issues/1895 -void registerNarayanaReflectiveClass(BuildProducer reflectiveClass) { -reflectiveClass.produce( -new ReflectiveClassBuildItem(false, false, SocketProcessId.class.getName())); -} }
[GitHub] [camel-quarkus] jamesnetherton closed issue #1895: Remove JtaProcessor.registerNarayanaReflectiveClass when quarkusio/quarkus#10180 gets fixed
jamesnetherton closed issue #1895: URL: https://github.com/apache/camel-quarkus/issues/1895 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] jamesnetherton merged pull request #2165: Fix #1895 to remove registerNarayanaReflectiveClass
jamesnetherton merged pull request #2165: URL: https://github.com/apache/camel-quarkus/pull/2165 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-quarkus] branch camel-master updated (6148e4d -> 4343bd5)
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a change to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. omit 6148e4d Upgrade to Camel 3.8.0 add 3770917 Avoid usage of deprecated capabilities string constants add 7d8d55f Google BigQuery native is since 1.6.0 not 1.5.0 add 9553e86 Upgrade Camel to 3.7.1 add 6023d9f IPFS native support add a0d82d7 Increased maven-plugin-version to 1.11.0.Final. Adjusted description of rest-json example new 4343bd5 Upgrade to Camel 3.8.0 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 (6148e4d) \ N -- N -- N refs/heads/camel-master (4343bd5) 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 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: .../reference/extensions/google-bigquery.adoc | 4 +- .../ROOT/pages/reference/extensions/ipfs.adoc | 8 +-- .../modules/ROOT/pages/user-guide/first-steps.adoc | 4 +- .../reference/components/google-bigquery-sql.adoc | 2 +- .../reference/components/google-bigquery.adoc | 2 +- .../ROOT/partials/reference/components/ipfs.adoc | 6 +- .../component/ipfs/deployment/IpfsProcessor.java | 46 extensions-jvm/ipfs/integration-test/pom.xml | 83 -- .../quarkus/component/ipfs/it/IpfsResource.java| 51 - .../camel/quarkus/component/ipfs/it/IpfsTest.java | 34 - extensions-jvm/pom.xml | 1 - extensions/google-bigquery/runtime/pom.xml | 2 +- .../ipfs/deployment/pom.xml| 0 .../component/ipfs/deployment/IpfsProcessor.java} | 6 +- {extensions-jvm => extensions}/ipfs/pom.xml| 1 - .../ipfs/runtime/pom.xml | 1 + .../main/resources/META-INF/quarkus-extension.yaml | 3 +- .../component/jta/deployment/JtaProcessor.java | 3 +- extensions/pom.xml | 1 + integration-tests/{twilio => ipfs}/pom.xml | 23 +++--- .../quarkus/component/ipfs/it/IpfsResource.java} | 33 + .../camel/quarkus/component/ipfs/it/IpfsIT.java} | 4 +- .../camel/quarkus/component/ipfs/it/IpfsTest.java | 79 .../component/ipfs/it/IpfsTestResource.java| 39 +- integration-tests/pom.xml | 1 + tooling/scripts/test-categories.yaml | 1 + 26 files changed, 154 insertions(+), 284 deletions(-) delete mode 100644 extensions-jvm/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java delete mode 100644 extensions-jvm/ipfs/integration-test/pom.xml delete mode 100644 extensions-jvm/ipfs/integration-test/src/main/java/org/apache/camel/quarkus/component/ipfs/it/IpfsResource.java delete mode 100644 extensions-jvm/ipfs/integration-test/src/test/java/org/apache/camel/quarkus/component/ipfs/it/IpfsTest.java rename {extensions-jvm => extensions}/ipfs/deployment/pom.xml (100%) copy extensions/{file/deployment/src/main/java/org/apache/camel/quarkus/component/file/deployment/FileProcessor.java => ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java} (88%) rename {extensions-jvm => extensions}/ipfs/pom.xml (97%) rename {extensions-jvm => extensions}/ipfs/runtime/pom.xml (98%) rename {extensions-jvm => extensions}/ipfs/runtime/src/main/resources/META-INF/quarkus-extension.yaml (97%) copy integration-tests/{twilio => ipfs}/pom.xml (91%) copy integration-tests/{csimple/src/main/java/org/apache/camel/quarkus/component/csimple/it/CSimpleResource.java => ipfs/src/main/java/org/apache/camel/quarkus/component/ipfs/it/IpfsResource.java} (63%) copy integration-tests/{amqp/src/test/java/org/apache/camel/quarkus/component/amqp/it/AmqpIT.java => ipfs/src/test/java/org/apache/camel/quarkus/component/ipfs/it/IpfsIT.java} (91%) create mode 100644 integration-tests/ipfs/src/test/java/org/apache/camel/quarkus/component/ipfs/it/IpfsTest.java copy extensions-jvm/nitrite/integration-test/src/test/java/org/apache/camel/quarkus/component/nitrite/it/NitriteTestResource.java =>
[camel-quarkus] 01/01: Upgrade to Camel 3.8.0
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 4343bd5854561f51d7d391b3e518341a90d5f1f2 Author: James Netherton AuthorDate: Wed Jan 6 08:53:07 2021 + Upgrade to Camel 3.8.0 --- docs/modules/ROOT/pages/reference/extensions/jsonata.adoc | 2 +- docs/modules/ROOT/pages/reference/extensions/sjms.adoc | 3 +-- .../modules/ROOT/partials/reference/components/jsonata.adoc | 4 ++-- .../ROOT/partials/reference/components/paho-mqtt5.adoc | 1 + .../ROOT/partials/reference/components/sjms-batch.adoc | 13 - .../ROOT/partials/reference/components/spring-rabbitmq.adoc | 1 + .../ROOT/partials/reference/others/flight-recorder.adoc | 1 + docs/modules/ROOT/partials/reference/others/jfr.adoc| 1 + .../apache/camel/component/qute/QuteEndpointConfigurer.java | 3 --- .../apache/camel/component/qute/QuteEndpointUriFactory.java | 3 +-- .../resources/org/apache/camel/component/qute/qute.json | 3 +-- pom.xml | 6 +++--- 12 files changed, 13 insertions(+), 28 deletions(-) diff --git a/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc b/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc index d22514b..3b53fd3 100644 --- a/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc +++ b/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc @@ -16,7 +16,7 @@ JSON to JSON transformation using JSONATA. == What's inside -* xref:{cq-camel-components}::jsonata-component.adoc[JSONATA component], URI syntax: `jsonata:resourceUri` +* xref:{cq-camel-components}::jsonata-component.adoc[JSONata component], URI syntax: `jsonata:resourceUri` Please refer to the above link for usage and configuration details. diff --git a/docs/modules/ROOT/pages/reference/extensions/sjms.adoc b/docs/modules/ROOT/pages/reference/extensions/sjms.adoc index a9c8263..ccbfe90 100644 --- a/docs/modules/ROOT/pages/reference/extensions/sjms.adoc +++ b/docs/modules/ROOT/pages/reference/extensions/sjms.adoc @@ -18,9 +18,8 @@ Send and receive messages to/from a JMS Queue or Topic using plain JMS 1.x API. == What's inside * xref:{cq-camel-components}::sjms-component.adoc[Simple JMS component], URI syntax: `sjms:destinationType:destinationName` -* xref:{cq-camel-components}::sjms-batch-component.adoc[Simple JMS Batch component], URI syntax: `sjms-batch:destinationName` -Please refer to the above links for usage and configuration details. +Please refer to the above link for usage and configuration details. == Maven coordinates diff --git a/docs/modules/ROOT/partials/reference/components/jsonata.adoc b/docs/modules/ROOT/partials/reference/components/jsonata.adoc index 0e6518d..2b9f794 100644 --- a/docs/modules/ROOT/partials/reference/components/jsonata.adoc +++ b/docs/modules/ROOT/partials/reference/components/jsonata.adoc @@ -8,6 +8,6 @@ :cq-jvm-since: 1.6.0 :cq-native-since: 1.6.0 :cq-camel-part-name: jsonata -:cq-camel-part-title: JSONATA -:cq-camel-part-description: JSON to JSON transformation using JSONATA. +:cq-camel-part-title: JSONata +:cq-camel-part-description: Transforms JSON payload using JSONata transformation. :cq-extension-page-title: JSONATA diff --git a/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc b/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc new file mode 100644 index 000..a509c1d --- /dev/null +++ b/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc @@ -0,0 +1 @@ +// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is included from a Camel page diff --git a/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc b/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc deleted file mode 100644 index eff2868..000 --- a/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc +++ /dev/null @@ -1,13 +0,0 @@ -// Do not edit directly! -// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page -:cq-artifact-id: camel-quarkus-sjms -:cq-artifact-id-base: sjms -:cq-native-supported: true -:cq-status: Stable -:cq-deprecated: false -:cq-jvm-since: 1.0.0 -:cq-native-since: 1.0.0 -:cq-camel-part-name: sjms-batch -:cq-camel-part-title: Simple JMS Batch -:cq-camel-part-description: Highly performant and transactional batch consumption of messages from a JMS queue. -:cq-extension-page-title: Simple JMS diff --git a/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc new file mode 100644 index 000..a509c1d --- /dev/null +++ b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc @@ -0,0 +1 @@ +// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is
[GitHub] [camel-k] astefanutti commented on issue #1923: [ppc64le] bundle image generated using `bundle` and `bundle-build` targets incompatible with `opm`
astefanutti commented on issue #1923: URL: https://github.com/apache/camel-k/issues/1923#issuecomment-766622022 @amitsadaphule maybe this can help: https://minikube.sigs.k8s.io/docs/handbook/registry/#enabling-insecure-registries. > One nifty hack is to allow the kubelet running in minikube to talk to registries deployed inside a pod in the cluster without backing them with TLS certificates. Because the default service cluster IP is known to be available at 10.0.0.1, users can pull images from registries deployed inside the cluster by creating the cluster with minikube start --insecure-registry "10.0.0.0/24". This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated (f239bc4 -> 435fc79)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from f239bc4 Regen for commit 48681f9ec80141d7590ba8d56340af6ed745e730 new 732cbf2 Upgrade AssertJ to version 3.19.0 new 435fc79 Sync deps The 2 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: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel] 02/02: Sync deps
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 435fc79a3b984d98c60427d0f859c3758aca5d01 Author: Andrea Cosentino AuthorDate: Mon Jan 25 08:34:30 2021 +0100 Sync deps --- camel-dependencies/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 6629fe0..f5a46df 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -56,7 +56,7 @@ 2.0.0.Final 8.0.1 1.9.6 -3.18.1 +3.19.0 1.0.0-final 2.1.2 3.0.0
[camel] 01/02: Upgrade AssertJ to version 3.19.0
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 732cbf2a8240d64ac7ae56b893a7caf489de2f8b Author: Andrea Cosentino AuthorDate: Mon Jan 25 08:31:45 2021 +0100 Upgrade AssertJ to version 3.19.0 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 78bf543..bd3c05e 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -64,7 +64,7 @@ 2.0.0.Final 8.0.1 1.9.6 -3.18.1 +3.19.0 1.0.0-final 2.1.2 3.0.0
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-766610270 @aryankoul can you rebase please? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (2e4362a -> f239bc4)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit 2e4362a Regen for commit 48681f9ec80141d7590ba8d56340af6ed745e730 add f239bc4 Regen for commit 48681f9ec80141d7590ba8d56340af6ed745e730 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 (2e4362a) \ N -- N -- N refs/heads/regen_bot (f239bc4) 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:
[camel] branch master updated: Regen for commit 48681f9ec80141d7590ba8d56340af6ed745e730
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new f239bc4 Regen for commit 48681f9ec80141d7590ba8d56340af6ed745e730 f239bc4 is described below commit f239bc4bba47559ce088b01bb33c914132586032 Author: oscerd AuthorDate: Mon Jan 25 06:29:58 2021 + Regen for commit 48681f9ec80141d7590ba8d56340af6ed745e730 Signed-off-by: GitHub --- .../resources/org/apache/camel/catalog/schemas/camel-spring.xsd | 8 1 file changed, 8 insertions(+) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd index 2167e5e..efd3087 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd @@ -2609,6 +2609,14 @@ this and can report the Camel application as DOWN. Default value: false ]]> + + + + +
[GitHub] [camel] oscerd merged pull request #4924: Generated sources regen
oscerd merged pull request #4924: URL: https://github.com/apache/camel/pull/4924 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-quarkus] 01/01: Upgrade to Quarkus 1.12.0.Final
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch quarkus-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 7620126b24d488341437704c775f4425ee145b6e Author: James Netherton AuthorDate: Thu Nov 12 07:00:19 2020 + Upgrade to Quarkus 1.12.0.Final --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 3a84c0f..b9f3cd2 100644 --- a/pom.xml +++ b/pom.xml @@ -92,7 +92,7 @@ ${squareup-okio-version} 7.46.0.Final 0.2.0 -1.11.0.Final +999-SNAPSHOT 0.3.0 1.1.1 0.22.0
[camel-quarkus] branch quarkus-master updated (feeffa0 -> 7620126)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch quarkus-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. discard feeffa0 Upgrade to Quarkus 1.12.0.Final add 9553e86 Upgrade Camel to 3.7.1 add 6023d9f IPFS native support add a0d82d7 Increased maven-plugin-version to 1.11.0.Final. Adjusted description of rest-json example new 7620126 Upgrade to Quarkus 1.12.0.Final 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 (feeffa0) \ N -- N -- N refs/heads/quarkus-master (7620126) 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 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: .../ROOT/pages/reference/extensions/ipfs.adoc | 8 +-- .../modules/ROOT/pages/user-guide/first-steps.adoc | 4 +- .../ROOT/partials/reference/components/ipfs.adoc | 6 +- .../partials/reference/components/jclouds.adoc | 2 +- .../component/ipfs/deployment/IpfsProcessor.java | 46 extensions-jvm/ipfs/integration-test/pom.xml | 83 -- .../quarkus/component/ipfs/it/IpfsResource.java| 51 - .../camel/quarkus/component/ipfs/it/IpfsTest.java | 34 - extensions-jvm/pom.xml | 1 - .../ipfs/deployment/pom.xml| 0 .../component/ipfs/deployment/IpfsProcessor.java} | 6 +- {extensions-jvm => extensions}/ipfs/pom.xml| 1 - .../ipfs/runtime/pom.xml | 1 + .../main/resources/META-INF/quarkus-extension.yaml | 3 +- extensions/pom.xml | 1 + integration-tests/{twilio => ipfs}/pom.xml | 23 +++--- .../quarkus/component/ipfs/it/IpfsResource.java} | 33 + .../camel/quarkus/component/ipfs/it/IpfsIT.java} | 4 +- .../camel/quarkus/component/ipfs/it/IpfsTest.java | 79 .../component/ipfs/it/IpfsTestResource.java| 39 +- integration-tests/pom.xml | 1 + pom.xml| 2 +- tooling/scripts/test-categories.yaml | 1 + 23 files changed, 149 insertions(+), 280 deletions(-) delete mode 100644 extensions-jvm/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java delete mode 100644 extensions-jvm/ipfs/integration-test/pom.xml delete mode 100644 extensions-jvm/ipfs/integration-test/src/main/java/org/apache/camel/quarkus/component/ipfs/it/IpfsResource.java delete mode 100644 extensions-jvm/ipfs/integration-test/src/test/java/org/apache/camel/quarkus/component/ipfs/it/IpfsTest.java rename {extensions-jvm => extensions}/ipfs/deployment/pom.xml (100%) copy extensions/{file/deployment/src/main/java/org/apache/camel/quarkus/component/file/deployment/FileProcessor.java => ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java} (88%) rename {extensions-jvm => extensions}/ipfs/pom.xml (97%) rename {extensions-jvm => extensions}/ipfs/runtime/pom.xml (98%) rename {extensions-jvm => extensions}/ipfs/runtime/src/main/resources/META-INF/quarkus-extension.yaml (97%) copy integration-tests/{twilio => ipfs}/pom.xml (91%) copy integration-tests/{csimple/src/main/java/org/apache/camel/quarkus/component/csimple/it/CSimpleResource.java => ipfs/src/main/java/org/apache/camel/quarkus/component/ipfs/it/IpfsResource.java} (63%) copy integration-tests/{amqp/src/test/java/org/apache/camel/quarkus/component/amqp/it/AmqpIT.java => ipfs/src/test/java/org/apache/camel/quarkus/component/ipfs/it/IpfsIT.java} (91%) create mode 100644 integration-tests/ipfs/src/test/java/org/apache/camel/quarkus/component/ipfs/it/IpfsTest.java copy extensions-jvm/nitrite/integration-test/src/test/java/org/apache/camel/quarkus/component/nitrite/it/NitriteTestResource.java => integration-tests/ipfs/src/test/java/org/apache/camel/quarkus/component/ipfs/it/IpfsTestResource.java (55%)
[GitHub] [camel-quarkus] github-actions[bot] closed issue #2161: [CI] - Quarkus Master Branch Build Failure
github-actions[bot] closed issue #2161: URL: https://github.com/apache/camel-quarkus/issues/2161 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2161: [CI] - Quarkus Master Branch Build Failure
github-actions[bot] commented on issue #2161: URL: https://github.com/apache/camel-quarkus/issues/2161#issuecomment-766581186 Build fixed with: * Camel Quarkus Commit: 7620126b24d488341437704c775f4425ee145b6e * Quarkus Master Commit: a0d82d7d0f1da49dd86d794fe1bde9c6e855c69f * Link to build: https://github.com/apache/camel-quarkus/actions/runs/508355413 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (78e62de -> 2e4362a)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 78e62de CAMEL-16072: Nicer log summary of startup and shutdown of Camel add fd86e39 Upgrade Johnzon to version 1.2.10 add a9fcea4 Fixed tests add 48681f9 Regen and sync deps add 2e4362a Regen for commit 48681f9ec80141d7590ba8d56340af6ed745e730 No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 2 +- .../java/org/apache/camel/component/jsonb/JsonbAttributeOrderTest.java | 2 +- parent/pom.xml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-)
[GitHub] [camel] github-actions[bot] opened a new pull request #4924: Generated sources regen
github-actions[bot] opened a new pull request #4924: URL: https://github.com/apache/camel/pull/4924 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] tadayosi opened a new pull request #4923: CAMEL-16077: camel-undertow - not respect content-type specified by REST DSL produces when body returns null
tadayosi opened a new pull request #4923: URL: https://github.com/apache/camel/pull/4923 - [x] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. - [x] Each commit in the pull request should have a meaningful subject line and body. - [x] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. - [x] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [x] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md https://issues.apache.org/jira/browse/CAMEL-16077 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] 03/03: Regen and sync deps
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 48681f9ec80141d7590ba8d56340af6ed745e730 Author: Andrea Cosentino AuthorDate: Mon Jan 25 06:52:05 2021 +0100 Regen and sync deps --- camel-dependencies/pom.xml| 2 +- .../resources/org/apache/camel/catalog/schemas/camel-spring.xsd | 8 2 files changed, 1 insertion(+), 9 deletions(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 6f9a476..6629fe0 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -340,7 +340,7 @@ 1.26 2.8.0 2.10.6 -1.2.8 +1.2.10 1.6.2 0.1.1 0.9.12 diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd index efd3087..2167e5e 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd @@ -2609,14 +2609,6 @@ this and can report the Camel application as DOWN. Default value: false ]]> - - - - -
[camel] branch master updated (78e62de -> 48681f9)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 78e62de CAMEL-16072: Nicer log summary of startup and shutdown of Camel new fd86e39 Upgrade Johnzon to version 1.2.10 new a9fcea4 Fixed tests new 48681f9 Regen and sync deps The 3 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: camel-dependencies/pom.xml| 2 +- .../resources/org/apache/camel/catalog/schemas/camel-spring.xsd | 8 .../org/apache/camel/component/jsonb/JsonbAttributeOrderTest.java | 2 +- parent/pom.xml| 2 +- 4 files changed, 3 insertions(+), 11 deletions(-)
[camel] 02/03: Fixed tests
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit a9fcea423e970ad94a254ad291dae7b68ecda4dd Author: Andrea Cosentino AuthorDate: Mon Jan 25 06:36:47 2021 +0100 Fixed tests --- .../java/org/apache/camel/component/jsonb/JsonbAttributeOrderTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbAttributeOrderTest.java b/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbAttributeOrderTest.java index 9c87522..225d74e 100644 --- a/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbAttributeOrderTest.java +++ b/components/camel-jsonb/src/test/java/org/apache/camel/component/jsonb/JsonbAttributeOrderTest.java @@ -30,7 +30,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals; public class JsonbAttributeOrderTest extends CamelTestSupport { final String expectedJson -= "{\"bg\":123.123,\"bool\":true,\"doubleNumber\":123.123,\"floatNumber\":123.0,\"intNumber\":123,\"longNumber\":123}"; += "{\"bg\":\"123.123\",\"bool\":true,\"doubleNumber\":123.123,\"floatNumber\":123.0,\"intNumber\":123,\"longNumber\":123}"; @Test public void testMarshalAndUnmarshalMap() throws Exception {
[camel] 01/03: Upgrade Johnzon to version 1.2.10
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit fd86e39a86918dd69be991a61b682642c3644ce3 Author: Andrea Cosentino AuthorDate: Mon Jan 25 06:33:12 2021 +0100 Upgrade Johnzon to version 1.2.10 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 40abace..78bf543 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -330,7 +330,7 @@ 0.9.12 3.14.4 0.9.13 -1.2.8 +1.2.10 0.6.4 2.1.1 0.1.11
[camel-spring-boot] branch master updated: [create-pull-request] automated change
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/master by this push: new ace95d4 [create-pull-request] automated change ace95d4 is described below commit ace95d46427b7dc5a9872ee76e8f0f465e45ecb4 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Mon Jan 25 01:13:04 2021 + [create-pull-request] automated change --- .../camel/springboot/catalog/components/kafka.json | 1 + .../springboot/catalog/components/vertx-kafka.json | 2 ++ .../src/main/docs/kafka-starter.adoc | 3 ++- .../springboot/KafkaComponentConfiguration.java | 20 .../kafka/springboot/KafkaComponentConverter.java| 2 ++ .../src/main/docs/vertx-kafka-starter.adoc | 3 ++- .../springboot/VertxKafkaComponentConfiguration.java | 19 +++ .../springboot/VertxKafkaComponentConverter.java | 2 ++ docs/modules/ROOT/pages/kafka-starter.adoc | 3 ++- docs/modules/ROOT/pages/vertx-kafka-starter.adoc | 3 ++- 10 files changed, 54 insertions(+), 4 deletions(-) diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json index 311e2d7..ab26b6f 100644 --- a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json +++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json @@ -92,6 +92,7 @@ "workerPoolCoreSize": { "kind": "property", "displayName": "Worker Pool Core Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Number of core threads for the worker pool for continue routing Exchange after [...] "workerPoolMaxSize": { "kind": "property", "displayName": "Worker Pool Max Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "20", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Maximum number of threads for the worker pool for continue routing Exchange after [...] "autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...] +"kafkaClientFactory": { "kind": "property", "displayName": "Kafka Client Factory", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false, "autowired": false, "secret": false, "description": "Factory to use for creating org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances. This allows to configure a custom factory to c [...] "synchronous": { "kind": "property", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Sets whether synchronous processing should be strictly used" }, "schemaRegistryURL": { "kind": "property", "displayName": "Schema Registry URL", "group": "confluent", "label": "confluent", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "URL of the Confluent Platform schema registry servers to use. The format is host1:port1,host2:port2. Thi [...] "interceptorClasses": { "kind": "property", "displayName": "Interceptor Classes", "group": "monitoring", "label": "common,monitoring", "required": false, "type":
[GitHub] [camel-spring-boot] oscerd merged pull request #266: [Github Actions] Periodic Sync Camel Spring Boot Master Branch
oscerd merged pull request #266: URL: https://github.com/apache/camel-spring-boot/pull/266 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zhfeng opened a new pull request #2165: Fix #1895 to remove registerNarayanaReflectiveClass
zhfeng opened a new pull request #2165: URL: https://github.com/apache/camel-quarkus/pull/2165 [ ] An issue should be filed for the change unless this is a trivial change (fixing a typo or similar). One issue should ideally be fixed by not more than one commit and the other way round, each commit should fix just one issue, without pulling in other changes. [ ] Each commit in the pull request should have a meaningful and properly spelled subject line and body. Copying the title of the associated issue is typically enough. Please include the issue number in the commit message prefixed by #. [ ] The pull request description should explain what the pull request does, how, and why. If the info is available in the associated issue or some other external document, a link is enough. [ ] Phrases like Fix # or Fixes # will auto-close the named issue upon merging the pull request. Using them is typically a good idea. [ ] Please run mvn process-resources -Pformat (and amend the changes if necessary) before sending the pull request. [ ] Contributor guide is your good friend: https://camel.apache.org/camel-quarkus/latest/contributor-guide.html This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zhfeng commented on issue #1895: Remove JtaProcessor.registerNarayanaReflectiveClass when quarkusio/quarkus#10180 gets fixed
zhfeng commented on issue #1895: URL: https://github.com/apache/camel-quarkus/issues/1895#issuecomment-766512913 The upstream fix has been in quarkus 1.10.3.Final This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch automatic-periodic-sync updated (de27336 -> c1fc4fa)
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-spring-boot.git. omit de27336 [create-pull-request] automated change add a1dd9f9 [create-pull-request] automated change add 21e3c05 CAMEL-16072: Nicer log summary of startup and shutdown of Camel add 3a945b8 Upgrade to spring boot 2.4.2 add c1fc4fa [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 (de27336) \ N -- N -- N refs/heads/automatic-periodic-sync (c1fc4fa) 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: archetypes/camel-archetype-spring-boot/pom.xml | 2 +- .../camel/springboot/catalog/components/kafka.json | 1 + .../springboot/catalog/components/vertx-kafka.json | 2 ++ .../src/main/docs/kafka-starter.adoc | 3 ++- .../springboot/KafkaComponentConfiguration.java | 20 .../kafka/springboot/KafkaComponentConverter.java| 2 ++ .../src/main/docs/vertx-kafka-starter.adoc | 3 ++- .../springboot/VertxKafkaComponentConfiguration.java | 19 +++ .../springboot/VertxKafkaComponentConverter.java | 2 ++ .../camel-spring-boot/src/main/docs/spring-boot.adoc | 5 +++-- .../spring/boot/CamelConfigurationProperties.java| 15 +++ docs/modules/ROOT/pages/kafka-starter.adoc | 3 ++- docs/modules/ROOT/pages/spring-boot.adoc | 7 --- docs/modules/ROOT/pages/vertx-kafka-starter.adoc | 3 ++- 14 files changed, 73 insertions(+), 14 deletions(-)
[GitHub] [camel-spring-boot] github-actions[bot] opened a new pull request #266: [Github Actions] Periodic Sync Camel Spring Boot Master Branch
github-actions[bot] opened a new pull request #266: URL: https://github.com/apache/camel-spring-boot/pull/266 Periodic Sync of Camel Spring Boot Master Branch with main Camel Master. see https://github.com/apache/camel-spring-boot/blob/master/.github/workflows/automatic-sync-master.yml This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-karaf] branch automatic-periodic-sync updated (424f7e3 -> fb92ea4)
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-karaf.git. from 424f7e3 camel-paho-mqtt5 add feature but it does not yet work in OSGi - bug in Eclipse add fb92ea4 CAMEL-16072: Nicer log summary of startup and shutdown of Camel No new revisions were added by this update. Summary of changes: .../org/apache/camel/blueprint/CamelContextFactoryBean.java | 13 + 1 file changed, 13 insertions(+)
[GitHub] [camel-kafka-connector] valdar edited a comment on issue #843: [Question] How to process avro message in S3 connector
valdar edited a comment on issue #843: URL: https://github.com/apache/camel-kafka-connector/issues/843#issuecomment-766459392 You need to configure the SMT to be used, try to add : ``` transforms: toJson transforms.toJson.type: org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar commented on issue #843: [Question] How to process avro message in S3 connector
valdar commented on issue #843: URL: https://github.com/apache/camel-kafka-connector/issues/843#issuecomment-766459392 You need to configure the SMT to be used, try to add : ``` transforms: toJson transforms.toJson.type: org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (3937ba0 -> 78e62de)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 3937ba0 Regen for commit 59103a66cae683f8d41438d9ace487e5f29a8159 add 78e62de CAMEL-16072: Nicer log summary of startup and shutdown of Camel No new revisions were added by this update. Summary of changes: .../main/java/org/apache/camel/impl/engine/AbstractCamelContext.java| 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel] branch master updated: CAMEL-16072: Nicer log summary of startup and shutdown of Camel
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 78e62de CAMEL-16072: Nicer log summary of startup and shutdown of Camel 78e62de is described below commit 78e62de2e81898ee80eadb038df211fdf33c602d Author: Claus Ibsen AuthorDate: Sun Jan 24 20:42:01 2021 +0100 CAMEL-16072: Nicer log summary of startup and shutdown of Camel --- .../main/java/org/apache/camel/impl/engine/AbstractCamelContext.java| 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java index e56b877..a29faf1 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java @@ -3138,7 +3138,7 @@ public abstract class AbstractCamelContext extends BaseService protected void doStop() throws Exception { stopWatch.restart(); -if (shutdownStrategy != null) { +if (shutdownStrategy != null && shutdownStrategy.getTimeUnit() != null) { long timeout = shutdownStrategy.getTimeUnit().toMillis(shutdownStrategy.getTimeout()); String to = TimeUtils.printDuration(timeout); LOG.info("Apache Camel {} ({}) shutting down (timeout:{})", getVersion(), getName(), to);
[GitHub] [camel] attrobit commented on pull request #4921: camel-milo: enabled connection caching again.
attrobit commented on pull request #4921: URL: https://github.com/apache/camel/pull/4921#issuecomment-766413102 Currently the connection get closed when component stops. But i think that is to late. I want to close the connection when the routes stops. How does the component recognizes when all routes stops? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (71f90c8 -> 3937ba0)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit 71f90c8 Regen for commit 59103a66cae683f8d41438d9ace487e5f29a8159 add 3937ba0 Regen for commit 59103a66cae683f8d41438d9ace487e5f29a8159 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 (71f90c8) \ N -- N -- N refs/heads/regen_bot (3937ba0) 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:
[camel] branch master updated: Regen for commit 59103a66cae683f8d41438d9ace487e5f29a8159
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 3937ba0 Regen for commit 59103a66cae683f8d41438d9ace487e5f29a8159 3937ba0 is described below commit 3937ba0e8abfd2a7d78bde894d986da257130448 Author: davsclaus AuthorDate: Sun Jan 24 18:05:50 2021 + Regen for commit 59103a66cae683f8d41438d9ace487e5f29a8159 Signed-off-by: GitHub --- .../generated/resources/org/apache/camel/catalog/components/kafka.json | 1 + .../resources/org/apache/camel/catalog/components/vertx-kafka.json | 2 ++ 2 files changed, 3 insertions(+) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json index 4c3d0eb..79709da 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json @@ -92,6 +92,7 @@ "workerPoolCoreSize": { "kind": "property", "displayName": "Worker Pool Core Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Number of core threads for the worker pool for continue routing Exchange after [...] "workerPoolMaxSize": { "kind": "property", "displayName": "Worker Pool Max Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "20", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Maximum number of threads for the worker pool for continue routing Exchange after [...] "autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...] +"kafkaClientFactory": { "kind": "property", "displayName": "Kafka Client Factory", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false, "autowired": false, "secret": false, "description": "Factory to use for creating org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances. This allows to configure a custom factory to c [...] "synchronous": { "kind": "property", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Sets whether synchronous processing should be strictly used" }, "schemaRegistryURL": { "kind": "property", "displayName": "Schema Registry URL", "group": "confluent", "label": "confluent", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "URL of the Confluent Platform schema registry servers to use. The format is host1:port1,host2:port2. Thi [...] "interceptorClasses": { "kind": "property", "displayName": "Interceptor Classes", "group": "monitoring", "label": "common,monitoring", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Sets interceptors for producer or consumers. Producer interceptors have to be classes implemen [...] diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-kafka.json index 53d336e..d08bb98 100644 ---
[GitHub] [camel] oscerd merged pull request #4922: Generated sources regen
oscerd merged pull request #4922: URL: https://github.com/apache/camel/pull/4922 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (3d980be -> 71f90c8)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 3d980be Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 add 120ff2f Adds config option 'vertxKafkaClientFactory' to camel-vertx-kafka (#4916) add 59103a6 Adds config option 'kafkaClientFactory' to camel-kafka (#4918) add 71f90c8 Regen for commit 59103a66cae683f8d41438d9ace487e5f29a8159 No new revisions were added by this update. Summary of changes: .../org/apache/camel/catalog/components/kafka.json | 1 + .../camel/catalog/components/vertx-kafka.json | 2 + .../apache/camel/catalog/docs/kafka-component.adoc | 3 +- .../camel/catalog/docs/vertx-kafka-component.adoc | 6 +- .../component/kafka/KafkaComponentConfigurer.java | 6 + .../org/apache/camel/component/kafka/kafka.json| 1 + .../camel-kafka/src/main/docs/kafka-component.adoc | 3 +- ...Factory.java => DefaultKafkaClientFactory.java} | 26 ++--- ...lCommitFactory.java => KafkaClientFactory.java} | 28 +++-- .../camel/component/kafka/KafkaComponent.java | 20 .../camel/component/kafka/KafkaConsumer.java | 2 +- .../camel/component/kafka/KafkaProducer.java | 2 +- .../vertx/kafka/VertxKafkaComponentConfigurer.java | 6 + .../vertx/kafka/VertxKafkaEndpointConfigurer.java | 6 + .../vertx/kafka/VertxKafkaEndpointUriFactory.java | 3 +- .../camel/component/vertx/kafka/vertx-kafka.json | 2 + .../src/main/docs/vertx-kafka-component.adoc | 6 +- .../kafka/DefaultVertxKafkaClientFactory.java | 28 ++--- ...Converter.java => VertxKafkaClientFactory.java} | 21 ++-- .../component/vertx/kafka/VertxKafkaConsumer.java | 3 +- .../component/vertx/kafka/VertxKafkaProducer.java | 3 +- .../configuration/BaseVertxKafkaConfiguration.java | 20 .../VertxKafkaProducerOperationsTest.java | 2 +- .../dsl/KafkaComponentBuilderFactory.java | 23 .../dsl/VertxKafkaComponentBuilderFactory.java | 22 .../dsl/VertxKafkaEndpointBuilderFactory.java | 126 + .../modules/ROOT/pages/kafka-component.adoc| 3 +- .../modules/ROOT/pages/vertx-kafka-component.adoc | 6 +- 28 files changed, 317 insertions(+), 63 deletions(-) copy components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java => DefaultKafkaClientFactory.java} (61%) copy components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java => KafkaClientFactory.java} (57%) copy test-infra/camel-test-infra-aws-common/src/test/java/org/apache/camel/test/infra/aws/common/services/AWSService.java => components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/DefaultVertxKafkaClientFactory.java (54%) copy components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/{VertxKafkaTypeConverter.java => VertxKafkaClientFactory.java} (62%)
[GitHub] [camel] github-actions[bot] opened a new pull request #4922: Generated sources regen
github-actions[bot] opened a new pull request #4922: URL: https://github.com/apache/camel/pull/4922 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated: Adds config option 'kafkaClientFactory' to camel-kafka (#4918)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 59103a6 Adds config option 'kafkaClientFactory' to camel-kafka (#4918) 59103a6 is described below commit 59103a66cae683f8d41438d9ace487e5f29a8159 Author: Javier Holguera AuthorDate: Sun Jan 24 17:23:51 2021 + Adds config option 'kafkaClientFactory' to camel-kafka (#4918) --- .../apache/camel/catalog/docs/kafka-component.adoc | 3 +- .../component/kafka/KafkaComponentConfigurer.java | 6 +++ .../org/apache/camel/component/kafka/kafka.json| 1 + .../camel-kafka/src/main/docs/kafka-component.adoc | 3 +- .../component/kafka/DefaultKafkaClientFactory.java | 34 + .../camel/component/kafka/KafkaClientFactory.java | 44 ++ .../camel/component/kafka/KafkaComponent.java | 20 ++ .../camel/component/kafka/KafkaConsumer.java | 2 +- .../camel/component/kafka/KafkaProducer.java | 2 +- .../dsl/KafkaComponentBuilderFactory.java | 23 +++ .../modules/ROOT/pages/kafka-component.adoc| 3 +- 11 files changed, 136 insertions(+), 5 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc index 630520a..85c4147 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc @@ -41,7 +41,7 @@ kafka:topic[?options] // component options: START -The Kafka component supports 98 options, which are listed below. +The Kafka component supports 99 options, which are listed below. @@ -118,6 +118,7 @@ The Kafka component supports 98 options, which are listed below. | *workerPoolCoreSize* (producer) | Number of core threads for the worker pool for continue routing Exchange after kafka server has acknowledge the message that was sent to it from KafkaProducer using asynchronous non-blocking processing. | 10 | Integer | *workerPoolMaxSize* (producer) | Maximum number of threads for the worker pool for continue routing Exchange after kafka server has acknowledge the message that was sent to it from KafkaProducer using asynchronous non-blocking processing. | 20 | Integer | *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc. | true | boolean +| *kafkaClientFactory* (advanced) | Factory to use for creating org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances. This allows to configure a custom factory to create org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances with logic that extends the vanilla Kafka clients. | | KafkaClientFactory | *synchronous* (advanced) | Sets whether synchronous processing should be strictly used | false | boolean | *schemaRegistryURL* (confluent) | URL of the Confluent Platform schema registry servers to use. The format is host1:port1,host2:port2. This is known as schema.registry.url in the Confluent Platform documentation. This option is only available in the Confluent Platform (not standard Apache Kafka) | | String | *interceptorClasses* (monitoring) | Sets interceptors for producer or consumers. Producer interceptors have to be classes implementing org.apache.kafka.clients.producer.ProducerInterceptor Consumer interceptors have to be classes implementing org.apache.kafka.clients.consumer.ConsumerInterceptor Note that if you use Producer interceptor on a consumer it will throw a class cast exception in runtime | | String diff --git a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java index 6ad0aef..1e2481e 100644 --- a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java +++ b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java @@ -84,6 +84,8 @@ public class KafkaComponentConfigurer extends PropertyConfigurerSupport implemen case "heartbeatIntervalMs": getOrCreateConfiguration(target).setHeartbeatIntervalMs(property(camelContext, java.lang.Integer.class, value)); return true;
[camel] branch master updated (3d980be -> 120ff2f)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 3d980be Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 add 120ff2f Adds config option 'vertxKafkaClientFactory' to camel-vertx-kafka (#4916) No new revisions were added by this update. Summary of changes: .../camel/catalog/docs/vertx-kafka-component.adoc | 6 +- .../vertx/kafka/VertxKafkaComponentConfigurer.java | 6 + .../vertx/kafka/VertxKafkaEndpointConfigurer.java | 6 + .../vertx/kafka/VertxKafkaEndpointUriFactory.java | 3 +- .../camel/component/vertx/kafka/vertx-kafka.json | 2 + .../src/main/docs/vertx-kafka-component.adoc | 6 +- .../kafka/DefaultVertxKafkaClientFactory.java | 28 ++--- ...Converter.java => VertxKafkaClientFactory.java} | 21 ++-- .../component/vertx/kafka/VertxKafkaConsumer.java | 3 +- .../component/vertx/kafka/VertxKafkaProducer.java | 3 +- .../configuration/BaseVertxKafkaConfiguration.java | 20 .../VertxKafkaProducerOperationsTest.java | 2 +- .../dsl/VertxKafkaComponentBuilderFactory.java | 22 .../dsl/VertxKafkaEndpointBuilderFactory.java | 126 + .../modules/ROOT/pages/vertx-kafka-component.adoc | 6 +- 15 files changed, 226 insertions(+), 34 deletions(-) copy test-infra/camel-test-infra-aws-common/src/test/java/org/apache/camel/test/infra/aws/common/services/AWSService.java => components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/DefaultVertxKafkaClientFactory.java (54%) copy components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/{VertxKafkaTypeConverter.java => VertxKafkaClientFactory.java} (62%)
[GitHub] [camel] davsclaus merged pull request #4918: [CAMEL-16071] Adds config option 'kafkaClientFactory' to camel-kafka
davsclaus merged pull request #4918: URL: https://github.com/apache/camel/pull/4918 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] davsclaus merged pull request #4916: [CAMEL-16071] Adds config option 'vertxKafkaClientFactory' to camel-vertx-kafka
davsclaus merged pull request #4916: URL: https://github.com/apache/camel/pull/4916 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch master updated: Upgrade to spring boot 2.4.2
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/master by this push: new 3a945b8 Upgrade to spring boot 2.4.2 3a945b8 is described below commit 3a945b8b475ad609f0deadb6efc31fb925f72a1b Author: Claus Ibsen AuthorDate: Sun Jan 24 18:22:27 2021 +0100 Upgrade to spring boot 2.4.2 --- archetypes/camel-archetype-spring-boot/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/archetypes/camel-archetype-spring-boot/pom.xml b/archetypes/camel-archetype-spring-boot/pom.xml index 466bf27..b212776 100644 --- a/archetypes/camel-archetype-spring-boot/pom.xml +++ b/archetypes/camel-archetype-spring-boot/pom.xml @@ -34,7 +34,7 @@ maven-archetype - 2.4.1 + 2.4.2 src/test/resources/settings.xml
[camel-spring-boot] branch master updated: CAMEL-16072: Nicer log summary of startup and shutdown of Camel
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/master by this push: new 21e3c05 CAMEL-16072: Nicer log summary of startup and shutdown of Camel 21e3c05 is described below commit 21e3c05acb197134d3974eab270549c6e61da92c Author: Claus Ibsen AuthorDate: Sun Jan 24 18:16:23 2021 +0100 CAMEL-16072: Nicer log summary of startup and shutdown of Camel --- core/camel-spring-boot/src/main/docs/spring-boot.adoc | 5 +++-- .../camel/spring/boot/CamelConfigurationProperties.java | 15 +++ docs/modules/ROOT/pages/spring-boot.adoc | 7 --- 3 files changed, 18 insertions(+), 9 deletions(-) diff --git a/core/camel-spring-boot/src/main/docs/spring-boot.adoc b/core/camel-spring-boot/src/main/docs/spring-boot.adoc index d90c23be..03eb4ad 100644 --- a/core/camel-spring-boot/src/main/docs/spring-boot.adoc +++ b/core/camel-spring-boot/src/main/docs/spring-boot.adoc @@ -92,7 +92,7 @@ When using spring-boot with Spring Boot make sure to use the following Maven dep -The component supports 165 options, which are listed below. +The component supports 166 options, which are listed below. @@ -188,7 +188,6 @@ The component supports 165 options, which are listed below. | *camel.springboot.route-controller-exclude-routes* | Pattern for filtering routes to be included as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to include all kafka routes, you can say kafka:*. And to include routes with specific route ids myRoute,myOtherRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPattern. | | String | *camel.springboot.route-controller-include-routes* | Pattern for filtering routes to be excluded as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to exclude all JMS routes, you can say jms:*. And to exclude routes with specific route ids mySpecialRoute,myOtherSpecialRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPatte [...] | *camel.springboot.route-controller-initial-delay* | Initial delay in milli seconds before the route controller starts, after CamelContext has been started. | 0 | Long -| *camel.springboot.route-controller-route-startup-logging-level* | Sets the logging level used for logging route startup activity. By default INFO level is used. You can use this to change the level for example to OFF if this kind of logging is not wanted. | | LoggingLevel | *camel.springboot.route-controller-supervise-enabled* | To enable using supervising route controller which allows Camel to startup and then the controller takes care of starting the routes in a safe manner. This can be used when you want to startup Camel despite a route may otherwise fail fast during startup and cause Camel to fail to startup as well. By delegating the route startup to the supervising route controller then it manages the startup using a background thread. The controlle [...] | *camel.springboot.route-controller-thread-pool-size* | The number of threads used by the route controller scheduled thread pool that are used for restarting routes. The pool uses 1 thread by default, but you can increase this to allow the controller to concurrently attempt to restart multiple routes in case more than one route has problems starting. | 1 | Integer | *camel.springboot.route-controller-unhealthy-on-exhausted* | Whether to mark the route as unhealthy (down) when all restarting attempts (backoff) have failed and the route is not successfully started and the route manager is giving up. Setting this to true allows health checks to know about this and can report the Camel application as DOWN. The default is false. | false | Boolean @@ -206,6 +205,7 @@ The component supports 165 options, which are listed below. | *camel.springboot.startup-recorder-max-depth* | To filter our sub steps at a maximum depth. Use -1 for no maximum. Use 0 for no sub steps. Use 1 for max 1 sub step, and so forth. The default is -1. | -1 | Integer | *camel.springboot.startup-recorder-profile* | To use a specific Java Flight Recorder profile configuration, such as default or profile. The default is default. | default | String | *camel.springboot.startup-recorder-recording* | To enable Java Flight Recorder to start a recording and automatic dump the recording to disk after startup is complete. This requires that camel-jfr is on the classpath. The default is true. | true | Boolean +| *camel.springboot.startup-summary-level* | Controls the level of information logged during startup (and shutdown) of CamelContext. | |
[camel-kafka-connector] tag camel-kafka-connector-0.7.1 updated (1fbfc86 -> bc6ddb7)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was modified! *** from 1fbfc86 (tag) to bc6ddb7 (commit) from d4b722b [maven-release-plugin] prepare release camel-kafka-connector-0.7.1 new bc6ddb7 [after release perform chore]: regen catalog descriptors with new version 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: .../src/generated/resources/connectors/camel-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json| 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-source.json| 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json| 2 +- .../src/generated/resources/connectors/camel-atmos-source.json | 2 +- .../generated/resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-multimap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddbstream-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ecs-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-eks-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-iam-sink.json | 2 +- .../generated/resources/connectors/camel-aws-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-kms-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-lambda-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-mq-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-msk-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-sdb-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-sink.json | 2 +-
[camel] branch regen_bot updated (f46ba15 -> 3d980be)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit f46ba15 Regen for commit dfd480197944810f4d8bc1996f953fbc593da3c8 add 3d980be Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 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 (f46ba15) \ N -- N -- N refs/heads/regen_bot (3d980be) 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:
[GitHub] [camel] attrobit commented on pull request #4921: camel-milo: enabled connection caching again.
attrobit commented on pull request #4921: URL: https://github.com/apache/camel/pull/4921#issuecomment-766390880 > Wasn't this removed? Yes, but i down know why. For me the caching are useful and for my usecases necessary. I will have round about 400 routes to the same OPC-UA server. I think it is not a good idea to have for each route a separate connection. The difference to the old version is that the connection are not created on component start. Now the connection instance are later careted on consumer or producer start. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] attrobit opened a new pull request #4921: camel-milo: enabled connection caching again.
attrobit opened a new pull request #4921: URL: https://github.com/apache/camel/pull/4921 - [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. - [ ] Each commit in the pull request should have a meaningful subject line and body. - [ ] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. - [ ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [ ] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master created (now 3d980be)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. at 3d980be Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 This branch includes the following new commits: new 3d980be Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 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.
[camel] 01/01: Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 3d980be2bd79a6e865e1aa0c2cb772d159b17502 Author: davsclaus AuthorDate: Sun Jan 24 15:57:47 2021 + Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 Signed-off-by: GitHub --- .../main/camel-main-configuration-metadata.json| 3 ++- .../apache/camel/catalog/models/camelContext.json | 1 + .../org/apache/camel/catalog/others.properties | 1 - .../camel/catalog/others/flight-recorder.json | 15 - .../apache/camel/catalog/schemas/camel-spring.xsd | 26 ++ docs/components/modules/others/pages/main.adoc | 1 + 6 files changed, 30 insertions(+), 17 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json index 7e0ddef..52e54cd 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json @@ -57,7 +57,7 @@ { "name": "camel.main.routeControllerExcludeRoutes", "description": "Pattern for filtering routes to be excluded as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to exclude all JMS routes, you can say jms:. And to exclude routes with specific route ids mySpecialRoute,myOtherSpecialRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPatter [...] { "name": "camel.main.routeControllerIncludeRoutes", "description": "Pattern for filtering routes to be included as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to include all kafka routes, you can say kafka:. And to include routes with specific route ids myRoute,myOtherRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPattern.", "sour [...] { "name": "camel.main.routeControllerInitialDelay", "description": "Initial delay in milli seconds before the route controller starts, after CamelContext has been started.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "integer", "javaType": "long" }, -{ "name": "camel.main.routeControllerLoggingLevel", "description": "Sets the logging level used for logging route activity (such as starting and stopping routes). The default logging level is DEBUG.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "object", "javaType": "org.apache.camel.LoggingLevel", "defaultValue": "DEBUG", "enum": [ "ERROR", "WARN", "INFO", "DEBUG", "TRACE", "OFF" ] }, +{ "name": "camel.main.routeControllerLoggingLevel", "description": "Sets the logging level used for logging route activity (such as starting and stopping routes). The default logging level is DEBUG.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "object", "javaType": "org.apache.camel.LoggingLevel", "defaultValue": "DEBUG", "enum": [ "ERROR", "WARN", "INFO", "DEBUG", "TRACE", "OFF" ], "deprecated": true }, { "name": "camel.main.routeControllerSuperviseEnabled", "description": "To enable using supervising route controller which allows Camel to startup and then the controller takes care of starting the routes in a safe manner. This can be used when you want to startup Camel despite a route may otherwise fail fast during startup and cause Camel to fail to startup as well. By delegating the route startup to the supervising route controller then its manages the startup using a background th [...] { "name": "camel.main.routeControllerThreadPoolSize", "description": "The number of threads used by the route controller scheduled thread pool that are used for restarting routes. The pool uses 1 thread by default, but you can increase this to allow the controller to concurrently attempt to restart multiple routes in case more than one route has problems starting.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "integer", "javaType": "int" }, { "name": "camel.main.routeControllerUnhealthyOnExhausted", "description": "Whether to mark the route as unhealthy (down) when all restarting attempts (backoff) have failed and the route is not successfully started and the route manager is giving up. Setting this to true allows health checks to know about this and can report the Camel application as DOWN. The default is false.", "sourceType":
[GitHub] [camel] oscerd merged pull request #4920: Generated sources regen
oscerd merged pull request #4920: URL: https://github.com/apache/camel/pull/4920 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (de6f8c1 -> f46ba15)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit de6f8c1 Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 add f98b6a8 Upgrade Jsonata to version 1.4.9 add dfd4801 Sync deps add f46ba15 Regen for commit dfd480197944810f4d8bc1996f953fbc593da3c8 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 (de6f8c1) \ N -- N -- N refs/heads/regen_bot (f46ba15) 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: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[GitHub] [camel] github-actions[bot] opened a new pull request #4920: Generated sources regen
github-actions[bot] opened a new pull request #4920: URL: https://github.com/apache/camel/pull/4920 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated: Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 3d980be Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 3d980be is described below commit 3d980be2bd79a6e865e1aa0c2cb772d159b17502 Author: davsclaus AuthorDate: Sun Jan 24 15:57:47 2021 + Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 Signed-off-by: GitHub --- .../main/camel-main-configuration-metadata.json| 3 ++- .../apache/camel/catalog/models/camelContext.json | 1 + .../org/apache/camel/catalog/others.properties | 1 - .../camel/catalog/others/flight-recorder.json | 15 - .../apache/camel/catalog/schemas/camel-spring.xsd | 26 ++ docs/components/modules/others/pages/main.adoc | 1 + 6 files changed, 30 insertions(+), 17 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json index 7e0ddef..52e54cd 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json @@ -57,7 +57,7 @@ { "name": "camel.main.routeControllerExcludeRoutes", "description": "Pattern for filtering routes to be excluded as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to exclude all JMS routes, you can say jms:. And to exclude routes with specific route ids mySpecialRoute,myOtherSpecialRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPatter [...] { "name": "camel.main.routeControllerIncludeRoutes", "description": "Pattern for filtering routes to be included as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to include all kafka routes, you can say kafka:. And to include routes with specific route ids myRoute,myOtherRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPattern.", "sour [...] { "name": "camel.main.routeControllerInitialDelay", "description": "Initial delay in milli seconds before the route controller starts, after CamelContext has been started.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "integer", "javaType": "long" }, -{ "name": "camel.main.routeControllerLoggingLevel", "description": "Sets the logging level used for logging route activity (such as starting and stopping routes). The default logging level is DEBUG.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "object", "javaType": "org.apache.camel.LoggingLevel", "defaultValue": "DEBUG", "enum": [ "ERROR", "WARN", "INFO", "DEBUG", "TRACE", "OFF" ] }, +{ "name": "camel.main.routeControllerLoggingLevel", "description": "Sets the logging level used for logging route activity (such as starting and stopping routes). The default logging level is DEBUG.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "object", "javaType": "org.apache.camel.LoggingLevel", "defaultValue": "DEBUG", "enum": [ "ERROR", "WARN", "INFO", "DEBUG", "TRACE", "OFF" ], "deprecated": true }, { "name": "camel.main.routeControllerSuperviseEnabled", "description": "To enable using supervising route controller which allows Camel to startup and then the controller takes care of starting the routes in a safe manner. This can be used when you want to startup Camel despite a route may otherwise fail fast during startup and cause Camel to fail to startup as well. By delegating the route startup to the supervising route controller then its manages the startup using a background th [...] { "name": "camel.main.routeControllerThreadPoolSize", "description": "The number of threads used by the route controller scheduled thread pool that are used for restarting routes. The pool uses 1 thread by default, but you can increase this to allow the controller to concurrently attempt to restart multiple routes in case more than one route has problems starting.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "integer", "javaType": "int" }, { "name": "camel.main.routeControllerUnhealthyOnExhausted", "description": "Whether to mark the route as unhealthy (down) when all restarting attempts (backoff) have failed and the route is not successfully started and the route manager is giving up. Setting
[GitHub] [camel] oscerd merged pull request #4919: Generated sources regen
oscerd merged pull request #4919: URL: https://github.com/apache/camel/pull/4919 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.1 created (now 1fbfc86)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 1fbfc86 (tag) tagging d4b722b1e3ba8faeeefdf0a13df12c503c00946f (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Sun Jan 24 16:59:49 2021 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.1 --- No new revisions were added by this update.
[camel] branch regen_bot updated (edbc9e8 -> de6f8c1)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from edbc9e8 Sync deps add 30c9926 CAMEL-16072: Nicer log summary of startup and shutdown of Camel add 3c45f2f CAMEL-16072: Nicer log summary of startup and shutdown of Camel add de6f8c1 Regen for commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 No new revisions were added by this update. Summary of changes: .../main/camel-main-configuration-metadata.json| 3 +- .../apache/camel/catalog/models/camelContext.json | 1 + .../apache/camel/catalog/schemas/camel-spring.xsd | 26 +++ .../camel/cdi/xml/CamelContextFactoryBean.java | 14 ++ .../org/apache/camel/spring/camelContext.json | 1 + .../camel/spring/CamelContextFactoryBean.java | 15 ++ .../resources/org/apache/camel/jaxb.index | 1 + .../main/java/org/apache/camel/CamelContext.java | 10 ++ .../org/apache/camel/CamelContextLifecycle.java| 15 +- ...nverterExists.java => StartupSummaryLevel.java} | 12 +- .../java/org/apache/camel/spi/RouteController.java | 16 +- .../org/apache/camel/spi/ShutdownStrategy.java | 13 ++ .../camel/spi/SupervisingRouteController.java | 6 + .../camel/impl/engine/AbstractCamelContext.java| 174 +++-- .../camel/impl/engine/DefaultRouteController.java | 15 +- .../camel/impl/engine/DefaultShutdownStrategy.java | 52 -- .../engine/DefaultSupervisingRouteController.java | 6 + .../camel/impl/engine/InternalRouteController.java | 9 +- .../impl/engine/InternalRouteStartupManager.java | 2 +- .../camel/impl/ExtendedCamelContextConfigurer.java | 6 + .../camel/impl/lw/LightweightCamelContext.java | 11 ++ .../impl/lw/LightweightRuntimeCamelContext.java| 22 ++- .../org/apache/camel/core/xml/routeController.json | 1 + .../core/xml/AbstractCamelContextFactoryBean.java | 10 ++ .../core/xml/CamelRouteControllerDefinition.java | 15 ++ .../impl/ShutdownGracefulTimeoutTriggerTest.java | 2 +- .../processor/RouteStartupLoggingLevelTest.java| 2 +- .../MainConfigurationPropertiesConfigurer.java | 18 ++- .../camel-main-configuration-metadata.json | 3 +- core/camel-main/src/main/docs/main.adoc| 3 +- .../org/apache/camel/main/BaseMainSupport.java | 14 +- .../camel/main/DefaultConfigurationConfigurer.java | 7 +- .../camel/main/DefaultConfigurationProperties.java | 70 +++-- .../main/MainSupervisingRouteControllerTest.java | 5 +- .../management/mbean/ManagedRouteController.java | 2 +- .../mbean/ManagedSupervisingRouteController.java | 2 +- docs/components/modules/others/pages/main.adoc | 3 +- 37 files changed, 509 insertions(+), 78 deletions(-) copy core/camel-api/src/main/java/org/apache/camel/{TypeConverterExists.java => StartupSummaryLevel.java} (82%)
[GitHub] [camel] github-actions[bot] opened a new pull request #4919: Generated sources regen
github-actions[bot] opened a new pull request #4919: URL: https://github.com/apache/camel/pull/4919 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (9f04a61 -> edbc9e8)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 9f04a61 Sync deps add 62ba0db Upgrade JSLT to version 0.1.11 add edbc9e8 Sync deps No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel] branch master updated (3c45f2f -> dfd4801)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 3c45f2f CAMEL-16072: Nicer log summary of startup and shutdown of Camel new f98b6a8 Upgrade Jsonata to version 1.4.9 new dfd4801 Sync deps The 2 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: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel] 01/02: Upgrade Jsonata to version 1.4.9
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit f98b6a801576ad86830dae74e8e033e43eede385 Author: Andrea Cosentino AuthorDate: Sun Jan 24 16:19:23 2021 +0100 Upgrade Jsonata to version 1.4.9 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 9e41c24..40abace 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -342,7 +342,7 @@ 2.4.0 1.1.1 2.3 -1.4.8 +1.4.9 1.13.1 10.4 2.3
[camel] 02/02: Sync deps
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit dfd480197944810f4d8bc1996f953fbc593da3c8 Author: Andrea Cosentino AuthorDate: Sun Jan 24 16:32:00 2021 +0100 Sync deps --- camel-dependencies/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 7769c38..6f9a476 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -358,7 +358,7 @@ 1.1.1 2.3 1.5.0 -1.4.8 +1.4.9 1.13.1 10.4 1.2
[camel] branch regen_bot updated (82e04e2 -> 9f04a61)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 82e04e2 Fixes checkstyle coding issues with camel-milo add 9421e32 Upgrade AWS SDK v2 to version 2.15.69 add 9f04a61 Sync deps No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel] branch master updated (edbc9e8 -> 3c45f2f)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from edbc9e8 Sync deps new 30c9926 CAMEL-16072: Nicer log summary of startup and shutdown of Camel new 3c45f2f CAMEL-16072: Nicer log summary of startup and shutdown of Camel The 2 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: .../main/camel-main-configuration-metadata.json| 2 +- .../org/apache/camel/catalog/others.properties | 1 + .../camel/catalog/others/flight-recorder.json | 8 +- .../camel/cdi/xml/CamelContextFactoryBean.java | 14 ++ .../org/apache/camel/spring/camelContext.json | 1 + .../camel/spring/CamelContextFactoryBean.java | 15 ++ .../resources/org/apache/camel/jaxb.index | 1 + .../main/java/org/apache/camel/CamelContext.java | 10 ++ .../org/apache/camel/CamelContextLifecycle.java| 15 +- ...nverterExists.java => StartupSummaryLevel.java} | 12 +- .../java/org/apache/camel/spi/RouteController.java | 16 +- .../org/apache/camel/spi/ShutdownStrategy.java | 13 ++ .../camel/spi/SupervisingRouteController.java | 6 + .../camel/impl/engine/AbstractCamelContext.java| 174 +++-- .../camel/impl/engine/DefaultRouteController.java | 15 +- .../camel/impl/engine/DefaultShutdownStrategy.java | 52 -- .../engine/DefaultSupervisingRouteController.java | 6 + .../camel/impl/engine/InternalRouteController.java | 9 +- .../impl/engine/InternalRouteStartupManager.java | 2 +- .../camel/impl/ExtendedCamelContextConfigurer.java | 6 + .../camel/impl/lw/LightweightCamelContext.java | 11 ++ .../impl/lw/LightweightRuntimeCamelContext.java| 22 ++- .../org/apache/camel/core/xml/routeController.json | 1 + .../core/xml/AbstractCamelContextFactoryBean.java | 10 ++ .../core/xml/CamelRouteControllerDefinition.java | 15 ++ .../impl/ShutdownGracefulTimeoutTriggerTest.java | 2 +- .../processor/RouteStartupLoggingLevelTest.java| 2 +- .../MainConfigurationPropertiesConfigurer.java | 18 ++- .../camel-main-configuration-metadata.json | 3 +- core/camel-main/src/main/docs/main.adoc| 3 +- .../org/apache/camel/main/BaseMainSupport.java | 14 +- .../camel/main/DefaultConfigurationConfigurer.java | 7 +- .../camel/main/DefaultConfigurationProperties.java | 70 +++-- .../main/MainSupervisingRouteControllerTest.java | 5 +- .../management/mbean/ManagedRouteController.java | 2 +- .../mbean/ManagedSupervisingRouteController.java | 2 +- docs/components/modules/others/pages/main.adoc | 2 +- 37 files changed, 485 insertions(+), 82 deletions(-) copy components/camel-jfr/src/generated/resources/jfr.json => catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others/flight-recorder.json (55%) copy core/camel-api/src/main/java/org/apache/camel/{TypeConverterExists.java => StartupSummaryLevel.java} (82%)
[camel] 02/02: CAMEL-16072: Nicer log summary of startup and shutdown of Camel
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 3c45f2f34bd72741cf82e6400d19bd7015cc78b3 Author: Claus Ibsen AuthorDate: Sun Jan 24 16:09:08 2021 +0100 CAMEL-16072: Nicer log summary of startup and shutdown of Camel --- .../org/apache/camel/cdi/xml/CamelContextFactoryBean.java | 14 ++ .../resources/org/apache/camel/spring/camelContext.json | 1 + .../org/apache/camel/spring/CamelContextFactoryBean.java | 15 +++ .../src/generated/resources/org/apache/camel/jaxb.index | 1 + .../main/java/org/apache/camel/StartupSummaryLevel.java | 3 +++ .../org/apache/camel/core/xml/routeController.json| 1 + .../camel/core/xml/AbstractCamelContextFactoryBean.java | 10 ++ .../camel/core/xml/CamelRouteControllerDefinition.java| 15 +++ 8 files changed, 60 insertions(+) diff --git a/components/camel-cdi/src/main/java/org/apache/camel/cdi/xml/CamelContextFactoryBean.java b/components/camel-cdi/src/main/java/org/apache/camel/cdi/xml/CamelContextFactoryBean.java index 7488254..a71cda8 100644 --- a/components/camel-cdi/src/main/java/org/apache/camel/cdi/xml/CamelContextFactoryBean.java +++ b/components/camel-cdi/src/main/java/org/apache/camel/cdi/xml/CamelContextFactoryBean.java @@ -34,6 +34,7 @@ import org.apache.camel.LoggingLevel; import org.apache.camel.RoutesBuilder; import org.apache.camel.ShutdownRoute; import org.apache.camel.ShutdownRunningTask; +import org.apache.camel.StartupSummaryLevel; import org.apache.camel.TypeConverterExists; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.core.xml.AbstractCamelContextFactoryBean; @@ -80,6 +81,10 @@ public class CamelContextFactoryBean extends AbstractCamelContextFactoryBean
[camel] 01/02: CAMEL-16072: Nicer log summary of startup and shutdown of Camel
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 30c9926c5d04214c850dc277706fe1977c8f48eb Author: Claus Ibsen AuthorDate: Sun Jan 24 15:49:42 2021 +0100 CAMEL-16072: Nicer log summary of startup and shutdown of Camel --- .../main/camel-main-configuration-metadata.json| 2 +- .../org/apache/camel/catalog/others.properties | 1 + .../camel/catalog/others/flight-recorder.json | 15 ++ .../main/java/org/apache/camel/CamelContext.java | 10 ++ .../org/apache/camel/CamelContextLifecycle.java| 15 +- .../org/apache/camel/StartupSummaryLevel.java} | 20 +-- .../java/org/apache/camel/spi/RouteController.java | 16 +- .../org/apache/camel/spi/ShutdownStrategy.java | 13 ++ .../camel/spi/SupervisingRouteController.java | 6 + .../camel/impl/engine/AbstractCamelContext.java| 174 +++-- .../camel/impl/engine/DefaultRouteController.java | 15 +- .../camel/impl/engine/DefaultShutdownStrategy.java | 52 -- .../engine/DefaultSupervisingRouteController.java | 6 + .../camel/impl/engine/InternalRouteController.java | 9 +- .../impl/engine/InternalRouteStartupManager.java | 2 +- .../camel/impl/ExtendedCamelContextConfigurer.java | 6 + .../camel/impl/lw/LightweightCamelContext.java | 11 ++ .../impl/lw/LightweightRuntimeCamelContext.java| 22 ++- .../impl/ShutdownGracefulTimeoutTriggerTest.java | 2 +- .../processor/RouteStartupLoggingLevelTest.java| 2 +- .../MainConfigurationPropertiesConfigurer.java | 18 ++- .../camel-main-configuration-metadata.json | 3 +- core/camel-main/src/main/docs/main.adoc| 3 +- .../org/apache/camel/main/BaseMainSupport.java | 14 +- .../camel/main/DefaultConfigurationConfigurer.java | 7 +- .../camel/main/DefaultConfigurationProperties.java | 70 +++-- .../main/MainSupervisingRouteControllerTest.java | 5 +- .../management/mbean/ManagedRouteController.java | 2 +- .../mbean/ManagedSupervisingRouteController.java | 2 +- docs/components/modules/others/pages/main.adoc | 2 +- 30 files changed, 442 insertions(+), 83 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json index 7e90a22..7e0ddef 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/camel-main-configuration-metadata.json @@ -57,7 +57,7 @@ { "name": "camel.main.routeControllerExcludeRoutes", "description": "Pattern for filtering routes to be excluded as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to exclude all JMS routes, you can say jms:. And to exclude routes with specific route ids mySpecialRoute,myOtherSpecialRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPatter [...] { "name": "camel.main.routeControllerIncludeRoutes", "description": "Pattern for filtering routes to be included as supervised. The pattern is matching on route id, and endpoint uri for the route. Multiple patterns can be separated by comma. For example to include all kafka routes, you can say kafka:. And to include routes with specific route ids myRoute,myOtherRoute. The pattern supports wildcards and uses the matcher from org.apache.camel.support.PatternHelper#matchPattern.", "sour [...] { "name": "camel.main.routeControllerInitialDelay", "description": "Initial delay in milli seconds before the route controller starts, after CamelContext has been started.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "integer", "javaType": "long" }, -{ "name": "camel.main.routeControllerRouteStartupLoggingLevel", "description": "Sets the logging level used for logging route startup activity. By default INFO level is used. You can use this to change the level for example to OFF if this kind of logging is not wanted.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "object", "javaType": "org.apache.camel.LoggingLevel", "defaultValue": "INFO", "enum": [ "ERROR", "WARN", "INFO", "DEBUG", "TRACE", "OFF" ] }, +{ "name": "camel.main.routeControllerLoggingLevel", "description": "Sets the logging level used for logging route activity (such as starting and stopping routes). The default logging level is DEBUG.", "sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type": "object", "javaType": "org.apache.camel.LoggingLevel", "defaultValue": "DEBUG", "enum":
[camel-karaf] branch master updated: CAMEL-16072: Nicer log summary of startup and shutdown of Camel
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-karaf.git The following commit(s) were added to refs/heads/master by this push: new fb92ea4 CAMEL-16072: Nicer log summary of startup and shutdown of Camel fb92ea4 is described below commit fb92ea404fbef25847f6823b69db26108035034c Author: Claus Ibsen AuthorDate: Sun Jan 24 16:03:56 2021 +0100 CAMEL-16072: Nicer log summary of startup and shutdown of Camel --- .../org/apache/camel/blueprint/CamelContextFactoryBean.java | 13 + 1 file changed, 13 insertions(+) diff --git a/components/camel-blueprint/src/main/java/org/apache/camel/blueprint/CamelContextFactoryBean.java b/components/camel-blueprint/src/main/java/org/apache/camel/blueprint/CamelContextFactoryBean.java index b63dcaa..ea220ab 100644 --- a/components/camel-blueprint/src/main/java/org/apache/camel/blueprint/CamelContextFactoryBean.java +++ b/components/camel-blueprint/src/main/java/org/apache/camel/blueprint/CamelContextFactoryBean.java @@ -35,6 +35,7 @@ import org.apache.camel.LoggingLevel; import org.apache.camel.RoutesBuilder; import org.apache.camel.ShutdownRoute; import org.apache.camel.ShutdownRunningTask; +import org.apache.camel.StartupSummaryLevel; import org.apache.camel.TypeConverterExists; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.properties.PropertiesComponent; @@ -97,6 +98,9 @@ public class CamelContextFactoryBean extends AbstractCamelContextFactoryBean
[camel] 01/02: Upgrade JSLT to version 0.1.11
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 62ba0dbe1559c423653ba5d2a327f3aec01f9438 Author: Andrea Cosentino AuthorDate: Sun Jan 24 16:05:00 2021 +0100 Upgrade JSLT to version 0.1.11 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 6503279..9e41c24 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -333,7 +333,7 @@ 1.2.8 0.6.4 2.1.1 -0.1.10 +0.1.11 2.3.11 0.1.55 1.2
[camel] 02/02: Sync deps
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit edbc9e89c61af6f9ed2d020a217718d1cc7c817e Author: Andrea Cosentino AuthorDate: Sun Jan 24 16:08:09 2021 +0100 Sync deps --- camel-dependencies/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index f633f65..7769c38 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -350,7 +350,7 @@ 1.0.0-beta7 0.1.55 2.1.1 -0.1.10 +0.1.11 2.3.11 1.2 1.0
[camel-kafka-connector] tag camel-kafka-connector-0.7.1 deleted (was ee75381)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was deleted! *** was ee75381 [after release perform chore]: regen catalog descriptors with new version This change permanently discards the following revisions: discard ee75381 [after release perform chore]: regen catalog descriptors with new version discard 4fe8c1d [maven-release-plugin] prepare release camel-kafka-connector-0.7.1
[camel] branch master updated (9f04a61 -> edbc9e8)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 9f04a61 Sync deps new 62ba0db Upgrade JSLT to version 0.1.11 new edbc9e8 Sync deps The 2 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: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated (e3e4673 -> dc8f444)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. discard e3e4673 [maven-release-plugin] prepare for next development iteration omit ee75381 [after release perform chore]: regen catalog descriptors with new version omit 4fe8c1d [maven-release-plugin] prepare release camel-kafka-connector-0.7.1 This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/camel-kafka-connector-0.7.x (dc8f444) \ O -- O -- O (e3e4673) 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: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- .../src/generated/resources/connectors/camel-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json | 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json| 2 +- .../src/generated/resources/connectors/camel-as2-source.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-source.json| 2 +- .../resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../generated/resources/connectors/camel-atomix-multimap-sink.json| 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink.json| 2 +- .../generated/resources/connectors/camel-aws-ddbstream-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-ecs-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-eks-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-iam-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-kms-sink.json| 2 +-
[GitHub] [camel] javierholguera opened a new pull request #4918: [CAMEL-16071] Adds config option 'kafkaClientFactory' to camel-kafka
javierholguera opened a new pull request #4918: URL: https://github.com/apache/camel/pull/4918 - [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. - [ ] Each commit in the pull request should have a meaningful subject line and body. - [ ] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. - [ ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [ ] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md Equivalent to #4916 for the `camel-kafka` component This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] tag camel-kafka-connector-0.7.1 updated (31475c2 -> ee75381)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was modified! *** from 31475c2 (commit) to ee75381 (commit) discard 31475c2 [after release perform chore]: regen catalog descriptors with new version discard 94892b1 [maven-release-plugin] prepare for next development iteration add ee75381 [after release perform chore]: regen catalog descriptors with new version This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the tag 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 (31475c2) \ N -- N -- N refs/tags/camel-kafka-connector-0.7.1 (ee75381) 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: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-activemq-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-ws-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-wss-kafka-connector/pom.xml | 2 +- connectors/camel-amqp-kafka-connector/pom.xml | 2 +- connectors/camel-apns-kafka-connector/pom.xml | 2 +- connectors/camel-arangodb-kafka-connector/pom.xml | 2 +- connectors/camel-as2-kafka-connector/pom.xml | 2 +- connectors/camel-asterisk-kafka-connector/pom.xml | 2 +- connectors/camel-atlasmap-kafka-connector/pom.xml | 2 +- connectors/camel-atmos-kafka-connector/pom.xml| 2 +- connectors/camel-atmosphere-websocket-kafka-connector/pom.xml | 2 +- connectors/camel-atom-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-map-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-messaging-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-multimap-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-queue-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-set-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-value-kafka-connector/pom.xml | 2 +- connectors/camel-avro-kafka-connector/pom.xml | 2 +- connectors/camel-aws-cw-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddbstream-kafka-connector/pom.xml| 2 +- connectors/camel-aws-ec2-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ecs-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eks-kafka-connector/pom.xml | 2 +- connectors/camel-aws-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kms-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-kafka-connector/pom.xml | 2 +- connectors/camel-aws-mq-kafka-connector/pom.xml | 2 +- connectors/camel-aws-msk-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sdb-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-kafka-connector/pom.xml | 2 +- connectors/camel-aws-swf-kafka-connector/pom.xml | 2 +- connectors/camel-aws-translate-kafka-connector/pom.xml| 2 +-
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated (31475c2 -> e3e4673)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. omit 31475c2 [after release perform chore]: regen catalog descriptors with new version omit 94892b1 [maven-release-plugin] prepare for next development iteration new ee75381 [after release perform chore]: regen catalog descriptors with new version new e3e4673 [maven-release-plugin] prepare for next development iteration 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 (31475c2) \ N -- N -- N refs/heads/camel-kafka-connector-0.7.x (e3e4673) 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 2 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:
[camel-kafka-connector] tag camel-kafka-connector-0.7.1 updated (3650693 -> 31475c2)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was modified! *** from 3650693 (tag) to 31475c2 (commit) from 4fe8c1d [maven-release-plugin] prepare release camel-kafka-connector-0.7.1 add 94892b1 [maven-release-plugin] prepare for next development iteration add 31475c2 [after release perform chore]: regen catalog descriptors with new version No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- .../src/generated/resources/connectors/camel-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json | 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json| 2 +- .../src/generated/resources/connectors/camel-as2-source.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-source.json| 2 +- .../resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../generated/resources/connectors/camel-atomix-multimap-sink.json| 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink.json| 2 +- .../generated/resources/connectors/camel-aws-ddbstream-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-ecs-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-eks-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-iam-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-kms-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-lambda-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-mq-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-msk-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink.json
[camel] 02/02: Sync deps
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 9f04a6195e1a64f1023aa92829f726e91a08addb Author: Andrea Cosentino AuthorDate: Sun Jan 24 15:42:33 2021 +0100 Sync deps --- camel-dependencies/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 2300b01..f633f65 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -71,7 +71,7 @@ 4.0.3 1.11.22 1.11.714 -2.15.68 +2.15.69 2.6.1 1.2.14 1.3.1
[camel] 01/02: Upgrade AWS SDK v2 to version 2.15.69
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 9421e329552b48b7bc52a874720c2c45b6c786be Author: Andrea Cosentino AuthorDate: Sun Jan 24 15:33:10 2021 +0100 Upgrade AWS SDK v2 to version 2.15.69 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 3cac716..6503279 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -78,7 +78,7 @@ 1.10.1 4.0.3 1.11.714 -2.15.68 +2.15.69 1.11.22 2.6.1 1.2.14
[camel] branch master updated (82e04e2 -> 9f04a61)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 82e04e2 Fixes checkstyle coding issues with camel-milo new 9421e32 Upgrade AWS SDK v2 to version 2.15.69 new 9f04a61 Sync deps The 2 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: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.1 created (now 3650693)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 3650693 (tag) tagging 4fe8c1df5ed7480640043bd95e6d14fd8284d54e (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Sun Jan 24 15:18:10 2021 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.1 --- No new revisions were added by this update.
[camel] branch regen_bot updated (0c1026d -> 82e04e2)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 0c1026d CAMEL-16072: Reduce logging noise on startup. Fix startup time to be total time, and output individual time per phase. add 811d93c camel-milo: added possibility to read node values via producer. (#4909) add 82e04e2 Fixes checkstyle coding issues with camel-milo No new revisions were added by this update. Summary of changes: .../camel/catalog/docs/milo-client-component.adoc | 19 +++ .../src/main/docs/milo-client-component.adoc | 19 +++ .../milo/client/MiloClientConnection.java | 7 +++ .../component/milo/client/MiloClientEndpoint.java | 2 +- .../component/milo/client/MiloClientProducer.java | 16 +- .../milo/client/internal/SubscriptionManager.java | 39 +++-- ...itorItemTest.java => ReadValuesClientTest.java} | 64 ++ .../modules/ROOT/pages/milo-client-component.adoc | 19 +++ 8 files changed, 142 insertions(+), 43 deletions(-) copy components/camel-milo/src/test/java/org/apache/camel/component/milo/{MonitorItemTest.java => ReadValuesClientTest.java} (55%)
[camel] branch master updated: Fixes checkstyle coding issues with camel-milo
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 82e04e2 Fixes checkstyle coding issues with camel-milo 82e04e2 is described below commit 82e04e20c61862dba2dfa331eea2f9d41de2bdfe Author: Javier Holguera AuthorDate: Sun Jan 24 13:23:13 2021 + Fixes checkstyle coding issues with camel-milo --- .../org/apache/camel/component/milo/client/MiloClientProducer.java| 4 ++-- .../java/org/apache/camel/component/milo/ReadValuesClientTest.java| 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientProducer.java b/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientProducer.java index 8de1e59..d04c3dc 100644 --- a/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientProducer.java +++ b/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientProducer.java @@ -30,6 +30,8 @@ import static java.lang.Boolean.TRUE; public class MiloClientProducer extends DefaultAsyncProducer { +private static final String HEADER_NODE_IDS = "CamelMiloNodeIds"; + private MiloClientConnection connection; private final ExpandedNodeId nodeId; @@ -37,8 +39,6 @@ public class MiloClientProducer extends DefaultAsyncProducer { private final boolean defaultAwaitWrites; -private static final String HEADER_NODE_IDS = "CamelMiloNodeIds"; - public MiloClientProducer(final MiloClientEndpoint endpoint, final MiloClientConnection connection, final boolean defaultAwaitWrites) { super(endpoint); diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/ReadValuesClientTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/ReadValuesClientTest.java index 7b082fd..0dad0c7 100644 --- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/ReadValuesClientTest.java +++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/ReadValuesClientTest.java @@ -70,7 +70,7 @@ public class ReadValuesClientTest extends AbstractMiloServerTest { } @Test -void testReadValues_Successful() throws Exception { +void testReadValuesSuccessful() throws Exception { this.test1Endpoint.expectedMinimumMessageCount(1); producer1.sendBody("Foo");
[GitHub] [camel] oscerd commented on pull request #4917: Fixes checkstyle coding issues with camel-milo
oscerd commented on pull request #4917: URL: https://github.com/apache/camel/pull/4917#issuecomment-766347747 Thank you This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd merged pull request #4917: Fixes checkstyle coding issues with camel-milo
oscerd merged pull request #4917: URL: https://github.com/apache/camel/pull/4917 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] javierholguera opened a new pull request #4917: Fixes checkstyle coding issues with camel-milo
javierholguera opened a new pull request #4917: URL: https://github.com/apache/camel/pull/4917 - [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. - [ ] Each commit in the pull request should have a meaningful subject line and body. - [ ] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. - [ ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [ ] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md Fixes issues with this PR breaking `master` due to checkstyle coding issues in `camel-milo` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] gohanbg commented on issue #843: [Question] How to process avro message in S3 connector
gohanbg commented on issue #843: URL: https://github.com/apache/camel-kafka-connector/issues/843#issuecomment-766342006 Sure, here it is ```yaml apiVersion: kafka.strimzi.io/v1alpha1 kind: KafkaConnector metadata: name: s3-sink-connector7 labels: strimzi.io/cluster: aws-connect spec: class: org.apache.camel.kafkaconnector.awss3.CamelAwss3SinkConnector tasksMax: 1 config: key.converter: org.apache.kafka.connect.storage.StringConverter value.converter: io.confluent.connect.avro.AvroConverter value.converter.schema.registry.url: http://confluent-cp-schema-registry.messaging.svc:8081 topics: companies camel.sink.path.bucketNameOrArn: THE_BUCKET_NAME camel.sink.endpoint.keyName: ${date:now:MMdd-HHmmssSSS}-${exchangeId} camel.sink.maxPollDuration: 1 camel.component.aws-s3.configuration.autocloseBody: false camel.component.aws-s3.accessKey: ${file:/opt/kafka/external-configuration/kafka-aws-credentials/kafka-s3-credentials.properties:aws_access_key_id} camel.component.aws-s3.secretKey: ${file:/opt/kafka/external-configuration/kafka-aws-credentials/kafka-s3-credentials.properties:aws_secret_access_key} camel.sink.endpoint.accessKey: ${file:/opt/kafka/external-configuration/kafka-aws-credentials/kafka-s3-credentials.properties:aws_access_key_id} camel.sink.endpoint.secretKey: ${file:/opt/kafka/external-configuration/kafka-aws-credentials/kafka-s3-credentials.properties:aws_secret_access_key} camel.component.aws-s3.region: THE_ZONE ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar commented on issue #843: [Question] How to process avro message in S3 connector
valdar commented on issue #843: URL: https://github.com/apache/camel-kafka-connector/issues/843#issuecomment-766341112 @gohanbg can you post the config you used to run the sink connector? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] gohanbg commented on issue #843: [Question] How to process avro message in S3 connector
gohanbg commented on issue #843: URL: https://github.com/apache/camel-kafka-connector/issues/843#issuecomment-766339293 Hello @valdar, Apologies for the delay, it was a busy week and I just managed to test the fix. Not sure whether I'm doing something wrong, but I get the same error. ``` Caused by: org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: org.apache.kafka.connect.data.Struct to the required type: java.io.InputStream with value Struct{company_name=House Stark,logo_url=https://static.wikia.nocookie.net/gameofthrones/images/8/8a/House-Stark-Main-Shield.PNG/revision/latest/scale-to-width-down/400?cb=20170101103142,background_url=https://media-exp1.licdn.com/dms/image/C4E1BAQEY67rO9YNpIw/company-background_1/0?e=1592661600=beta=w0K0h9L18D6HieYM1giMf7TqKGne4LKqieuENS4RqDw,company_id=7d4cb366-aedf-476e-b3fc-61b9b1fc55eb} ``` Here is what I did: 1. I checked out the project - https://github.com/apache/camel-kafka-connector (with the change that you made) 2. Did **maven clean install** 3. Got the jar file **kafka-connector-0.8.0-SNAPSHOT.jar** created 4. Added it to my kafka connect image - this is how the jars look like. I have both **camel-kafka-connector-0.7.0.jar** and **camel-kafka-connector-0.8.0-SNAPSHOT.jar** ``` annotations-13.0.jar camel-core-engine-3.7.0.jar commons-codec-1.15.jar jackson-datatype-jdk8-2.10.2.jar lz4-java-1.7.1.jar apicurio-registry-common-1.3.1.Final.jar camel-core-languages-3.7.0.jarcommons-compress-1.20.jar jackson-mapper-asl-1.9.13.jar medeia-validator-core-1.1.1.jar apicurio-registry-distro-connect-converter-1.3.0.Final.jar camel-core-model-3.7.0.jarcommons-logging-1.2.jar jboss-jaxrs-api_2.1_spec-2.0.1.Final.jar medeia-validator-jackson-1.1.1.jar apicurio-registry-rest-client-1.3.1.Final.jar camel-core-processor-3.7.0.jarcommon-utils-5.5.0.jar jmespath-java-1.11.714.jarNOTICE.txt apicurio-registry-utils-converter-1.3.1.Final.jar camel-core-reifier-3.7.0.jar connect-json-2.6.0.jar joda-time-2.8.1.jar okhttp-3.14.9.jar apicurio-registry-utils-serde-1.3.1.Final.jar camel-direct-3.7.0.jarconverter-jackson-2.9.0.jar kafka-avro-serializer-5.5.0.jar okio-1.17.2.jar avro-1.10.0.jar camel-jackson-3.7.0.jar httpclient-4.5.13.jar kafka-clients-2.6.0.jar protobuf-java-3.13.0.jar aws-java-sdk-core-1.11.714.jar camel-kafka-3.7.0.jar httpcore-4.4.14.jar kafka-connect-avro-converter-5.5.0.jarREADME.adoc aws-java-sdk-kms-1.11.714.jar camel-kafka-connector-0.7.0.jar ion-java-1.0.2.jar kafka-connect-avro-data-5.5.0.jar retrofit-2.9.0.jar aws-java-sdk-s3-1.11.714.jar camel-kafka-connector-0.8.0-SNAPSHOT.jar jackson-annotations-2.11.3.jar kafka-schema-registry-client-5.5.0.jarslf4j-api-1.7.30.jar camel-api-3.7.0.jar camel-main-3.7.0.jar jackson-core-2.11.3.jar kafka-schema-serializer-5.5.0.jar snappy-java-1.1.7.3.jar camel-aws-s3-3.7.0.jar camel-management-api-3.7.0.jarjackson-core-asl-1.9.13.jar kotlin-reflect-1.3.20.jar zstd-jni-1.4.4-7.jar camel-aws-s3-kafka-connector-0.7.0.jar camel-support-3.7.0.jar jackson-databind-2.11.3.jar kotlin-stdlib-1.3.20.jar camel-base-3.7.0.jar camel-util-3.7.0.jar jackson-dataformat-avro-2.11.3.jar kotlin-stdlib-common-1.3.20.jar camel-base-engine-3.7.0.jar common-config-5.5.0.jar jackson-dataformat-cbor-2.11.3.jar LICENSE.txt ``` 5. Deployed the kafka connect image to k8s 6. When I see the logs I can see that the update is processed ``` kubectl logs -f aws-connect-connect-76dc5478bd-tcjpr | grep SchemaAndStructToJsonTransform 2021-01-24 11:59:06,724 INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-01-24 11:59:09,940 INFO Added alias 'SchemaAndStructToJsonTransform' to plugin 'org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated (dd8f526 -> dc8f444)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from dd8f526 Upgrade to 3.7.1 and regen new 17b59c5 Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest new dc8f444 Added SchemaAndStructToJsonTransform fix #843 The 2 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: .../transforms/SchemaAndStructToJsonTransform.java | 77 ++ ...ava => SchemaAndStructToJsonTransformTest.java} | 45 +++-- .../SinkPojoToSchemaAndStructTransformTest.java| 3 +- 3 files changed, 101 insertions(+), 24 deletions(-) create mode 100644 core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java copy core/src/test/java/org/apache/camel/kafkaconnector/transforms/{SinkPojoToSchemaAndStructTransformTest.java => SchemaAndStructToJsonTransformTest.java} (62%)
[camel-kafka-connector] 01/02: Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 17b59c51d01bb4d80f2002bb234e3faaf0b1a907 Author: Andrea Tarocchi AuthorDate: Fri Jan 15 00:07:18 2021 +0100 Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest --- .../transforms/SinkPojoToSchemaAndStructTransformTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java index 5f1655a..4ac14ca 100644 --- a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java +++ b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java @@ -111,7 +111,8 @@ public class SinkPojoToSchemaAndStructTransformTest { Schema.STRING_SCHEMA, "testKeyValue", null, map); -sinkPojoToSchemaAndStructTransform.apply(cr); +ConnectRecord transformedCr = sinkPojoToSchemaAndStructTransform.apply(cr); +assertEquals(cr, transformedCr); } @Test()
[camel-kafka-connector] 02/02: Added SchemaAndStructToJsonTransform fix #843
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit dc8f444b972b1a015bfed2cd6476f83137e7c8bf Author: Andrea Tarocchi AuthorDate: Fri Jan 15 00:05:04 2021 +0100 Added SchemaAndStructToJsonTransform fix #843 --- .../transforms/SchemaAndStructToJsonTransform.java | 77 + .../SchemaAndStructToJsonTransformTest.java| 128 + 2 files changed, 205 insertions(+) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java new file mode 100644 index 000..72d10db --- /dev/null +++ b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.camel.kafkaconnector.transforms; + +import java.util.HashMap; +import java.util.Map; + +import org.apache.kafka.common.config.ConfigDef; +import org.apache.kafka.connect.connector.ConnectRecord; +import org.apache.kafka.connect.data.Schema; +import org.apache.kafka.connect.json.JsonConverter; +import org.apache.kafka.connect.json.JsonConverterConfig; +import org.apache.kafka.connect.storage.ConverterConfig; +import org.apache.kafka.connect.storage.ConverterType; +import org.apache.kafka.connect.transforms.Transformation; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class SchemaAndStructToJsonTransform> implements Transformation { +private static final Logger LOG = LoggerFactory.getLogger(SchemaAndStructToJsonTransform.class); + +private JsonConverter jsonConverter; + +@Override +public R apply(R r) { +LOG.debug("Incoming record: {}", r); + +if (r.value() != null && r.valueSchema() != null) { +byte[] json = jsonConverter.fromConnectData(r.topic(), r.valueSchema(), r.value()); + +if (json == null) { +LOG.warn("No record was converted as part of this transformation, resulting json byte[] was null."); +return r; +} + +LOG.debug("Json created: {}", new String(json)); + +return r.newRecord(r.topic(), r.kafkaPartition(), r.keySchema(), r.key(), +Schema.BYTES_SCHEMA, json, r.timestamp()); +} else { +LOG.debug("Incoming record with a null value or a null schema, nothing to be done."); +return r; +} +} + +@Override +public ConfigDef config() { +return JsonConverterConfig.configDef(); +} + +@Override +public void close() { +//NOOP +} + +@Override +public void configure(Map configs) { +jsonConverter = new JsonConverter(); +Map conf = new HashMap<>(configs); +conf.put(ConverterConfig.TYPE_CONFIG, ConverterType.VALUE.getName()); +jsonConverter.configure(conf); +} +} \ No newline at end of file diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransformTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransformTest.java new file mode 100644 index 000..159c7d7 --- /dev/null +++ b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransformTest.java @@ -0,0 +1,128 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY
[GitHub] [camel] davsclaus commented on a change in pull request #4916: [CAMEL-16071] Adds config option 'vertxKafkaClientFactory' to camel-vertx-kafka
davsclaus commented on a change in pull request #4916: URL: https://github.com/apache/camel/pull/4916#discussion_r563278270 ## File path: components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/configuration/BaseVertxKafkaConfiguration.java ## @@ -26,6 +28,9 @@ @UriParam(label = "common") private HeaderFilterStrategy headerFilterStrategy = new VertxKafkaHeaderFilterStrategy(); +@UriParam(label = "common") Review comment: Can we mark this option as advanced (as it would be seldom in use) This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] orpiske merged pull request #915: Added new integration test for AWS 2 EC2
orpiske merged pull request #915: URL: https://github.com/apache/camel-kafka-connector/pull/915 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] branch master updated: Added new integration test for AWS 2 EC2
This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/master by this push: new db4fa44 Added new integration test for AWS 2 EC2 db4fa44 is described below commit db4fa44ba9a622fa3b879d30fd77adafb5582bb5 Author: Otavio Rodolfo Piske AuthorDate: Fri Jan 22 14:51:26 2021 +0100 Added new integration test for AWS 2 EC2 --- tests/itests-aws-v2/pom.xml| 7 ++ .../aws/v2/common/CamelSinkAWSTestSupport.java | 12 +++ .../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 7 +- .../v2/ec2/sink/CamelAWSEC2PropertyFactory.java| 73 + .../sink/CamelSinkAWSEC2ITCase.java} | 91 ++ .../aws/v2/ec2/sink/TestEC2Configuration.java | 35 + 6 files changed, 168 insertions(+), 57 deletions(-) diff --git a/tests/itests-aws-v2/pom.xml b/tests/itests-aws-v2/pom.xml index caf3c28..8669c50 100644 --- a/tests/itests-aws-v2/pom.xml +++ b/tests/itests-aws-v2/pom.xml @@ -72,6 +72,13 @@ org.apache.camel camel-aws2-cw + + +org.apache.camel +camel-aws2-ec2 + + + diff --git a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java index a66a474..6f77de6 100644 --- a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java +++ b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java @@ -17,6 +17,7 @@ package org.apache.camel.kafkaconnector.aws.v2.common; +import java.time.Duration; import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; @@ -72,6 +73,17 @@ public abstract class CamelSinkAWSTestSupport extends AbstractKafkaTest { verifyMessages(latch); } +protected boolean waitForData() { +try { +Thread.sleep(Duration.ofSeconds(1).toMillis()); +return true; +} catch (InterruptedException e) { +Thread.currentThread().interrupt(); + +return false; +} +} + protected abstract void consumeMessages(CountDownLatch latch); protected abstract void verifyMessages(CountDownLatch latch) throws InterruptedException; diff --git a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java index 0888b10..71f56f1 100644 --- a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java +++ b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java @@ -17,7 +17,6 @@ package org.apache.camel.kafkaconnector.aws.v2.cw.sink; -import java.time.Duration; import java.util.HashMap; import java.util.Map; import java.util.Properties; @@ -113,11 +112,7 @@ public class CamelSinkAWSCWITCase extends CamelSinkAWSTestSupport { } } -try { -Thread.sleep(Duration.ofSeconds(1).toMillis()); -} catch (InterruptedException e) { -Thread.currentThread().interrupt(); - +if (!waitForData()) { break; } } diff --git a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/ec2/sink/CamelAWSEC2PropertyFactory.java b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/ec2/sink/CamelAWSEC2PropertyFactory.java new file mode 100644 index 000..3a35bbb --- /dev/null +++ b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/ec2/sink/CamelAWSEC2PropertyFactory.java @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License.
[GitHub] [camel-kafka-connector] valdar merged pull request #917: Upgrade to 3.7.1 and regen
valdar merged pull request #917: URL: https://github.com/apache/camel-kafka-connector/pull/917 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated: Upgrade to 3.7.1 and regen
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-0.7.x by this push: new dd8f526 Upgrade to 3.7.1 and regen dd8f526 is described below commit dd8f52658a1047ec3379946d8b111aec36aa4b84 Author: Andrea Cosentino AuthorDate: Fri Jan 22 18:20:21 2021 +0100 Upgrade to 3.7.1 and regen --- .../resources/connectors/camel-activemq-sink.json | 2 +- .../resources/connectors/camel-activemq-source.json| 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json | 2 +- .../generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../resources/connectors/camel-ahc-ws-source.json | 2 +- .../generated/resources/connectors/camel-ahc-wss-sink.json | 2 +- .../resources/connectors/camel-ahc-wss-source.json | 2 +- .../generated/resources/connectors/camel-amqp-sink.json| 2 +- .../generated/resources/connectors/camel-amqp-source.json | 2 +- .../generated/resources/connectors/camel-apns-sink.json| 2 +- .../generated/resources/connectors/camel-apns-source.json | 2 +- .../resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json | 2 +- .../generated/resources/connectors/camel-as2-source.json | 2 +- .../resources/connectors/camel-asterisk-sink.json | 2 +- .../resources/connectors/camel-asterisk-source.json| 2 +- .../resources/connectors/camel-atlasmap-sink.json | 2 +- .../generated/resources/connectors/camel-atmos-sink.json | 2 +- .../generated/resources/connectors/camel-atmos-source.json | 2 +- .../connectors/camel-atmosphere-websocket-sink.json| 2 +- .../connectors/camel-atmosphere-websocket-source.json | 2 +- .../generated/resources/connectors/camel-atom-source.json | 2 +- .../resources/connectors/camel-atomix-map-sink.json| 2 +- .../resources/connectors/camel-atomix-map-source.json | 2 +- .../resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../connectors/camel-atomix-messaging-source.json | 2 +- .../resources/connectors/camel-atomix-multimap-sink.json | 2 +- .../resources/connectors/camel-atomix-queue-sink.json | 2 +- .../resources/connectors/camel-atomix-queue-source.json| 2 +- .../resources/connectors/camel-atomix-set-sink.json| 2 +- .../resources/connectors/camel-atomix-set-source.json | 2 +- .../resources/connectors/camel-atomix-value-sink.json | 2 +- .../resources/connectors/camel-atomix-value-source.json| 2 +- .../generated/resources/connectors/camel-avro-sink.json| 2 +- .../generated/resources/connectors/camel-avro-source.json | 2 +- .../generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ddb-sink.json | 2 +- .../resources/connectors/camel-aws-ddbstream-source.json | 2 +- .../generated/resources/connectors/camel-aws-ec2-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ecs-sink.json | 2 +- .../generated/resources/connectors/camel-aws-eks-sink.json | 2 +- .../generated/resources/connectors/camel-aws-iam-sink.json | 2 +- .../connectors/camel-aws-kinesis-firehose-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source.json | 2 +- .../generated/resources/connectors/camel-aws-kms-sink.json | 2 +- .../resources/connectors/camel-aws-lambda-sink.json| 2 +- .../generated/resources/connectors/camel-aws-mq-sink.json | 2 +- .../generated/resources/connectors/camel-aws-msk-sink.json | 2 +- .../generated/resources/connectors/camel-aws-s3-sink.json | 2 +- .../resources/connectors/camel-aws-s3-source.json | 2 +- .../generated/resources/connectors/camel-aws-sdb-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ses-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-sink.json | 2 +- .../resources/connectors/camel-aws-sqs-source.json | 2 +- .../generated/resources/connectors/camel-aws-swf-sink.json | 2 +- .../resources/connectors/camel-aws-swf-source.json | 2 +- .../resources/connectors/camel-aws-translate-sink.json | 2 +- .../resources/connectors/camel-aws2-athena-sink.json | 2 +- .../generated/resources/connectors/camel-aws2-cw-sink.json | 2 +- .../resources/connectors/camel-aws2-ddb-sink.json | 2 +- .../resources/connectors/camel-aws2-ddbstream-source.json | 2 +- .../resources/connectors/camel-aws2-ec2-sink.json | 2 +- .../resources/connectors/camel-aws2-ecs-sink.json | 2 +- .../resources/connectors/camel-aws2-eks-sink.json
[GitHub] [camel-spring-boot] oscerd merged pull request #265: [Github Actions] Periodic Sync Camel Spring Boot Master Branch
oscerd merged pull request #265: URL: https://github.com/apache/camel-spring-boot/pull/265 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org