You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/03/23 05:31:07 UTC
[camel-spring-boot] branch master updated (434f313e -> 0cccead)
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-spring-boot.git.
from 434f313e Regen
new cbc9311 Polished
new 0cccead Polished
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:
.../org/apache/camel/springboot/catalog/components/kafka.json | 4 ++--
components-starter/camel-as2-starter/pom.xml | 2 +-
components-starter/camel-aws-secrets-manager-starter/pom.xml | 2 +-
components-starter/camel-aws-xray-starter/pom.xml | 2 +-
components-starter/camel-azure-eventhubs-starter/pom.xml | 2 +-
components-starter/camel-google-functions-starter/pom.xml | 2 +-
.../camel/component/kafka/springboot/KafkaComponentConfiguration.java | 3 ++-
dsl-starter/camel-xml-io-dsl-starter/pom.xml | 4 ++--
8 files changed, 11 insertions(+), 10 deletions(-)
[camel-spring-boot] 01/02: Polished
Posted by da...@apache.org.
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
commit cbc93118e3d695eb99ff5ae43f052c1a8ee54fbb
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Mar 23 06:29:24 2021 +0100
Polished
---
.../org/apache/camel/springboot/catalog/components/kafka.json | 4 ++--
components-starter/camel-aws-secrets-manager-starter/pom.xml | 2 +-
components-starter/camel-aws-xray-starter/pom.xml | 2 +-
components-starter/camel-azure-eventhubs-starter/pom.xml | 2 +-
components-starter/camel-google-functions-starter/pom.xml | 2 +-
.../camel/component/kafka/springboot/KafkaComponentConfiguration.java | 3 ++-
6 files changed, 8 insertions(+), 7 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 8ddb617..21b585d 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
@@ -52,7 +52,7 @@
"maxPollRecords": { "kind": "property", "displayName": "Max Poll Records", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of records returned in a single call to poll()" },
"offsetRepository": { "kind": "property", "displayName": "Offset Repository", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "org.apache.camel.spi.StateRepository<java.lang.String, java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The offset repository to use in order to locally stor [...]
"partitionAssignor": { "kind": "property", "displayName": "Partition Assignor", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The class name of the partition assignme [...]
- "pollOnError": { "kind": "property", "displayName": "Poll On Error", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [ "DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "What to do if kafka [...]
+ "pollOnError": { "kind": "property", "displayName": "Poll On Error", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [ "DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "ERROR_HANDLER", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "de [...]
"pollTimeoutMs": { "kind": "property", "displayName": "Poll Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5000", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The timeout used when polling the KafkaConsumer." },
"seekTo": { "kind": "property", "displayName": "Seek To", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from beginning or end on startup: beginning : read from beginning [...]
"sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10000", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect failures when using Kafka's group management facilities." },
@@ -155,7 +155,7 @@
"maxPollRecords": { "kind": "parameter", "displayName": "Max Poll Records", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The maximum number of records returned in a single call to poll()" },
"offsetRepository": { "kind": "parameter", "displayName": "Offset Repository", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "org.apache.camel.spi.StateRepository<java.lang.String, java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The offset repository to use in order to locally sto [...]
"partitionAssignor": { "kind": "parameter", "displayName": "Partition Assignor", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.clients.consumer.RangeAssignor", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The class name of the partition assignm [...]
- "pollOnError": { "kind": "parameter", "displayName": "Poll On Error", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [ "DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "What to do if kafka [...]
+ "pollOnError": { "kind": "parameter", "displayName": "Poll On Error", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "org.apache.camel.component.kafka.PollOnError", "enum": [ "DISCARD", "ERROR_HANDLER", "RECONNECT", "RETRY", "STOP" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "ERROR_HANDLER", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "d [...]
"pollTimeoutMs": { "kind": "parameter", "displayName": "Poll Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5000", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The timeout used when polling the KafkaConsumer." },
"seekTo": { "kind": "parameter", "displayName": "Seek To", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Set if KafkaConsumer will read from beginning or end on startup: beginning : read from beginning [...]
"sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10000", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "The timeout used to detect failures when using Kafka's group management facilities." },
diff --git a/components-starter/camel-aws-secrets-manager-starter/pom.xml b/components-starter/camel-aws-secrets-manager-starter/pom.xml
index a66babe..31f9374 100644
--- a/components-starter/camel-aws-secrets-manager-starter/pom.xml
+++ b/components-starter/camel-aws-secrets-manager-starter/pom.xml
@@ -26,7 +26,7 @@
</parent>
<artifactId>camel-aws-secrets-manager-starter</artifactId>
<packaging>jar</packaging>
- <!-- <name>Camel SB Starters :: Name Here</name>-->
+ <name>Camel SB Starters :: AWS Secrets Manager</name>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
diff --git a/components-starter/camel-aws-xray-starter/pom.xml b/components-starter/camel-aws-xray-starter/pom.xml
index b78cd5f..fbb50d0a 100644
--- a/components-starter/camel-aws-xray-starter/pom.xml
+++ b/components-starter/camel-aws-xray-starter/pom.xml
@@ -26,7 +26,7 @@
</parent>
<artifactId>camel-aws-xray-starter</artifactId>
<packaging>jar</packaging>
- <name>Camel SB Starters :: AWS :: XRay</name>
+ <name>Camel SB Starters :: AWS XRay</name>
<description>Spring-Boot Starter for Distributed tracing using AWS XRay</description>
<dependencies>
<dependency>
diff --git a/components-starter/camel-azure-eventhubs-starter/pom.xml b/components-starter/camel-azure-eventhubs-starter/pom.xml
index 3413e6f..ee900d1 100644
--- a/components-starter/camel-azure-eventhubs-starter/pom.xml
+++ b/components-starter/camel-azure-eventhubs-starter/pom.xml
@@ -26,7 +26,7 @@
</parent>
<artifactId>camel-azure-eventhubs-starter</artifactId>
<packaging>jar</packaging>
- <name>Camel SB Starters :: Azure-Eventhubs</name>
+ <name>Camel SB Starters :: Azure Eventhubs</name>
<description>Spring-Boot Starter for Camel Support for Azure Eventhubs Service</description>
<dependencies>
<dependency>
diff --git a/components-starter/camel-google-functions-starter/pom.xml b/components-starter/camel-google-functions-starter/pom.xml
index 41b2132..1aa57e4 100644
--- a/components-starter/camel-google-functions-starter/pom.xml
+++ b/components-starter/camel-google-functions-starter/pom.xml
@@ -26,7 +26,7 @@
</parent>
<artifactId>camel-google-functions-starter</artifactId>
<packaging>jar</packaging>
- <!-- <name>Camel SB Starters :: Name Here</name>-->
+ <name>Camel SB Starters :: Google Functions</name>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
diff --git a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
index 7f6a7f1..075719c 100644
--- a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
+++ b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
@@ -20,6 +20,7 @@ import java.util.Map;
import java.util.concurrent.ExecutorService;
import javax.annotation.Generated;
import org.apache.camel.component.kafka.KafkaClientFactory;
+import org.apache.camel.component.kafka.KafkaComponent;
import org.apache.camel.component.kafka.KafkaConfiguration;
import org.apache.camel.component.kafka.KafkaManualCommitFactory;
import org.apache.camel.component.kafka.PollExceptionStrategy;
@@ -263,7 +264,7 @@ public class KafkaComponentConfiguration
* started/restarted if the consumer should be able to consume messages
* again)
*/
- private PollOnError pollOnError;
+ private PollOnError pollOnError = PollOnError.ERROR_HANDLER;
/**
* The timeout used when polling the KafkaConsumer. The option is a
* java.lang.Long type.
[camel-spring-boot] 02/02: Polished
Posted by da...@apache.org.
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
commit 0cccead6c75806602a494e45d90618b1c95153dc
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Mar 23 06:30:54 2021 +0100
Polished
---
components-starter/camel-as2-starter/pom.xml | 2 +-
dsl-starter/camel-xml-io-dsl-starter/pom.xml | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/components-starter/camel-as2-starter/pom.xml b/components-starter/camel-as2-starter/pom.xml
index 094e762..7b11652 100644
--- a/components-starter/camel-as2-starter/pom.xml
+++ b/components-starter/camel-as2-starter/pom.xml
@@ -26,7 +26,7 @@
</parent>
<artifactId>camel-as2-starter</artifactId>
<packaging>jar</packaging>
- <name>Camel SB Starters :: AS2 :: Component</name>
+ <name>Camel SB Starters :: AS2</name>
<description>Spring-Boot Starter for Camel AS2 component</description>
<dependencies>
<dependency>
diff --git a/dsl-starter/camel-xml-io-dsl-starter/pom.xml b/dsl-starter/camel-xml-io-dsl-starter/pom.xml
index 59fed88..894c554 100644
--- a/dsl-starter/camel-xml-io-dsl-starter/pom.xml
+++ b/dsl-starter/camel-xml-io-dsl-starter/pom.xml
@@ -31,8 +31,8 @@
<artifactId>camel-xml-io-dsl-starter</artifactId>
<packaging>jar</packaging>
- <name>Camel SB DSL Starters :: XML Io Starter</name>
- <description>Spring-Boot Starter for Camel DSL :: XML Io</description>
+ <name>Camel SB DSL Starters :: XML IO Starter</name>
+ <description>Spring-Boot Starter for Camel DSL :: XML IO</description>
<dependencies>
<dependency>