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 dee61cd Regen
dee61cd is described below
commit dee61cd80b8eb8fea0b31ba48755b3c13e2e47c5
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Mar 13 16:08:50 2020 +0100
Regen
---
.../camel/springboot/catalog/components/elsql.json | 2 +-
.../camel/springboot/catalog/components/pulsar.json | 6 ++++--
.../apache/camel/springboot/catalog/components/sql.json | 2 +-
.../src/main/docs/pulsar-starter.adoc | 5 +++--
.../pulsar/springboot/PulsarComponentConfiguration.java | 16 +++++++++++++++-
docs/modules/ROOT/pages/pulsar-starter.adoc | 5 +++--
6 files changed, 27 insertions(+), 9 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elsql.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elsql.json
index 2941f6d..fac19cf 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elsql.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elsql.json
@@ -56,7 +56,7 @@
"batch": { "kind": "parameter", "displayName": "Batch", "group":
"producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "description": "Enables or disables batch mode" },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the [...]
"noop": { "kind": "parameter", "displayName": "Noop", "group": "producer",
"label": "producer", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": false,
"description": "If set, will ignore the results of the SQL query and use the
existing IN message as the OUT message for the continuation of processing" },
- "useMessageBodyForSql": { "kind": "parameter", "displayName": "Use Message
Body For Sql", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether to use the message body as the
SQL and then headers for parameters. If this option is enabled then the SQL in
the uri is not used." },
+ "useMessageBodyForSql": { "kind": "parameter", "displayName": "Use Message
Body For Sql", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether to use the message body as the
SQL and then headers for parameters. If this option is enabled then the SQL in
the uri is not used. Note that query parameters in the message body are
represented by a question ma [...]
"alwaysPopulateStatement": { "kind": "parameter", "displayName": "Always
Populate Statement", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": false, "description": "If enabled then the
populateStatement method from
org.apache.camel.component.sql.SqlPrepareStatementStrategy is always invoked,
also if there is no expected parameters to be prepared. When this is false then
the po [...]
"basicPropertyBinding": { "kind": "parameter", "displayName": "Basic
Property Binding", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the endpoint should use basic
property binding (Camel 2.x) or the newer property binding with additional
capabilities" },
"elSqlConfig": { "kind": "parameter", "displayName": "El Sql Config",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "com.opengamma.elsql.ElSqlConfig", "deprecated": false, "secret":
false, "description": "To use a specific configured ElSqlConfig. It may be
better to use the databaseVendor option instead." },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
index e1c0450..bf123f2 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
@@ -33,8 +33,9 @@
"numberOfConsumers": { "kind": "property", "displayName": "Number Of
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Number of consumers - defaults to 1" },
"subscriptionInitialPosition": { "kind": "property", "displayName":
"Subscription Initial Position", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition",
"enum": [ "EARLIEST", "LATEST" ], "deprecated": false, "secret": false,
"defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", [...]
"subscriptionName": { "kind": "property", "displayName": "Subscription
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "subs", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Name of the subscription to use" },
- "subscriptionType": { "kind": "property", "displayName": "Subscription
Type", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER" ], "deprecated": false, "secret": false,
"defaultValue": "EXCLUSIVE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "T [...]
+ "subscriptionType": { "kind": "property", "displayName": "Subscription
Type", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER", "KEY_SHARED" ], "deprecated": false,
"secret": false, "defaultValue": "EXCLUSIVE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "de [...]
"pulsarMessageReceiptFactory": { "kind": "property", "displayName":
"Pulsar Message Receipt Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.PulsarMessageReceiptFactory", "deprecated":
false, "secret": false, "description": "Provide a factory to create an
alternate implementation of PulsarMessageReceipt." },
+ "batcherBuilder": { "kind": "property", "displayName": "Batcher Builder",
"group": "producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.pulsar.client.api.BatcherBuilder", "deprecated": false,
"secret": false, "defaultValue": "DEFAULT", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Control batching method used by the producer."
},
"batchingEnabled": { "kind": "property", "displayName": "Batching
Enabled", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Control whether automatic batching of messages
is enabled for the producer." },
"batchingMaxMessages": { "kind": "property", "displayName": "Batching Max
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1000", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum size to batch messages." },
"batchingMaxPublishDelayMicros": { "kind": "property", "displayName":
"Batching Max Publish Delay Micros", "group": "producer", "label": "producer",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"secret": false, "defaultValue": "1000", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum time period within which the
messages sent will be batched if batchingEna [...]
@@ -70,9 +71,10 @@
"numberOfConsumers": { "kind": "parameter", "displayName": "Number Of
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Number of consumers - defaults to 1" },
"subscriptionInitialPosition": { "kind": "parameter", "displayName":
"Subscription Initial Position", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition",
"enum": [ "EARLIEST", "LATEST" ], "deprecated": false, "secret": false,
"defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfigur [...]
"subscriptionName": { "kind": "parameter", "displayName": "Subscription
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "subs", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Name of the subscription to use" },
- "subscriptionType": { "kind": "parameter", "displayName": "Subscription
Type", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER" ], "deprecated": false, "secret": false,
"defaultValue": "EXCLUSIVE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "descripti [...]
+ "subscriptionType": { "kind": "parameter", "displayName": "Subscription
Type", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER", "KEY_SHARED" ], "deprecated": false,
"secret": false, "defaultValue": "EXCLUSIVE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguratio [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "secret": false, "description": "To let the consumer use a
custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled
then this option is not in use. By default the consumer will deal with [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
+ "batcherBuilder": { "kind": "parameter", "displayName": "Batcher Builder",
"group": "producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.pulsar.client.api.BatcherBuilder", "deprecated": false,
"secret": false, "defaultValue": "DEFAULT", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Control batching method used by the
producer." },
"batchingEnabled": { "kind": "parameter", "displayName": "Batching
Enabled", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Control whether automatic batching of
messages is enabled for the producer." },
"batchingMaxMessages": { "kind": "parameter", "displayName": "Batching Max
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1000", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The maximum size to batch messages." },
"batchingMaxPublishDelayMicros": { "kind": "parameter", "displayName":
"Batching Max Publish Delay Micros", "group": "producer", "label": "producer",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"secret": false, "defaultValue": "1000", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The maximum time period within which the
messages sent will be batched if batc [...]
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sql.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sql.json
index 888992d..13dd3da 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sql.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sql.json
@@ -52,7 +52,7 @@
"batch": { "kind": "parameter", "displayName": "Batch", "group":
"producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "description": "Enables or disables batch mode" },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the [...]
"noop": { "kind": "parameter", "displayName": "Noop", "group": "producer",
"label": "producer", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": false,
"description": "If set, will ignore the results of the SQL query and use the
existing IN message as the OUT message for the continuation of processing" },
- "useMessageBodyForSql": { "kind": "parameter", "displayName": "Use Message
Body For Sql", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether to use the message body as the
SQL and then headers for parameters. If this option is enabled then the SQL in
the uri is not used." },
+ "useMessageBodyForSql": { "kind": "parameter", "displayName": "Use Message
Body For Sql", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether to use the message body as the
SQL and then headers for parameters. If this option is enabled then the SQL in
the uri is not used. Note that query parameters in the message body are
represented by a question ma [...]
"alwaysPopulateStatement": { "kind": "parameter", "displayName": "Always
Populate Statement", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": false, "description": "If enabled then the
populateStatement method from
org.apache.camel.component.sql.SqlPrepareStatementStrategy is always invoked,
also if there is no expected parameters to be prepared. When this is false then
the po [...]
"basicPropertyBinding": { "kind": "parameter", "displayName": "Basic
Property Binding", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the endpoint should use basic
property binding (Camel 2.x) or the newer property binding with additional
capabilities" },
"parametersCount": { "kind": "parameter", "displayName": "Parameters
Count", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"description": "If set greater than zero, then Camel will use this count value
of parameters to replace instead of querying via JDBC metadata API. This is
useful if the JDBC vendor could not return correct parameters count, then user
may override instead." },
diff --git
a/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
b/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
index 830e40b..966fd6e 100644
--- a/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
+++ b/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
@@ -17,7 +17,7 @@ When using pulsar with Spring Boot make sure to use the
following Maven dependen
----
-The component supports 33 options, which are listed below.
+The component supports 34 options, which are listed below.
@@ -29,6 +29,7 @@ The component supports 33 options, which are listed below.
| *camel.component.pulsar.allow-manual-acknowledgement* | Whether to allow
manual message acknowledgements. If this option is enabled, then messages are
not acknowledged automatically after successful route completion. Instead, an
instance of PulsarMessageReceipt is stored as a header on the
org.apache.camel.Exchange. Messages can then be acknowledged using
PulsarMessageReceipt at any time before the ackTimeout occurs. | false | Boolean
| *camel.component.pulsar.auto-configuration* | The pulsar auto configuration.
The option is a org.apache.camel.component.pulsar.utils.AutoConfiguration type.
| | String
| *camel.component.pulsar.basic-property-binding* | Whether the component
should use basic property binding (Camel 2.x) or the newer property binding
with additional capabilities | false | Boolean
+| *camel.component.pulsar.batcher-builder* | Control batching method used by
the producer. The option is a org.apache.pulsar.client.api.BatcherBuilder type.
| | String
| *camel.component.pulsar.batching-enabled* | Control whether automatic
batching of messages is enabled for the producer. | true | Boolean
| *camel.component.pulsar.batching-max-messages* | The maximum size to batch
messages. | 1000 | Integer
| *camel.component.pulsar.batching-max-publish-delay-micros* | The maximum
time period within which the messages sent will be batched if batchingEnabled
is true. | 1000 | Long
@@ -56,6 +57,6 @@ The component supports 33 options, which are listed below.
| *camel.component.pulsar.send-timeout-ms* | Send timeout in milliseconds |
30000 | Integer
| *camel.component.pulsar.subscription-initial-position* | Control the initial
position in the topic of a newly created subscription. Default is latest
message. | | SubscriptionInitialPosition
| *camel.component.pulsar.subscription-name* | Name of the subscription to use
| subs | String
-| *camel.component.pulsar.subscription-type* | Type of the subscription
EXCLUSIVESHAREDFAILOVER, defaults to EXCLUSIVE | | SubscriptionType
+| *camel.component.pulsar.subscription-type* | Type of the subscription
EXCLUSIVESHAREDFAILOVERKEY_SHARED, defaults to EXCLUSIVE | | SubscriptionType
|===
// spring-boot-auto-configure options: END
diff --git
a/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
b/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
index 09bfebc..f5f60f8 100644
---
a/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
+++
b/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
@@ -117,7 +117,8 @@ public class PulsarComponentConfiguration
*/
private String subscriptionName = "subs";
/**
- * Type of the subscription EXCLUSIVESHAREDFAILOVER, defaults to EXCLUSIVE
+ * Type of the subscription EXCLUSIVESHAREDFAILOVERKEY_SHARED, defaults to
+ * EXCLUSIVE
*/
private SubscriptionType subscriptionType = SubscriptionType.EXCLUSIVE;
/**
@@ -127,6 +128,11 @@ public class PulsarComponentConfiguration
*/
private String pulsarMessageReceiptFactory;
/**
+ * Control batching method used by the producer. The option is a
+ * org.apache.pulsar.client.api.BatcherBuilder type.
+ */
+ private String batcherBuilder;
+ /**
* Control whether automatic batching of messages is enabled for the
* producer.
*/
@@ -341,6 +347,14 @@ public class PulsarComponentConfiguration
this.pulsarMessageReceiptFactory = pulsarMessageReceiptFactory;
}
+ public String getBatcherBuilder() {
+ return batcherBuilder;
+ }
+
+ public void setBatcherBuilder(String batcherBuilder) {
+ this.batcherBuilder = batcherBuilder;
+ }
+
public Boolean getBatchingEnabled() {
return batchingEnabled;
}
diff --git a/docs/modules/ROOT/pages/pulsar-starter.adoc
b/docs/modules/ROOT/pages/pulsar-starter.adoc
index 830e40b..966fd6e 100644
--- a/docs/modules/ROOT/pages/pulsar-starter.adoc
+++ b/docs/modules/ROOT/pages/pulsar-starter.adoc
@@ -17,7 +17,7 @@ When using pulsar with Spring Boot make sure to use the
following Maven dependen
----
-The component supports 33 options, which are listed below.
+The component supports 34 options, which are listed below.
@@ -29,6 +29,7 @@ The component supports 33 options, which are listed below.
| *camel.component.pulsar.allow-manual-acknowledgement* | Whether to allow
manual message acknowledgements. If this option is enabled, then messages are
not acknowledged automatically after successful route completion. Instead, an
instance of PulsarMessageReceipt is stored as a header on the
org.apache.camel.Exchange. Messages can then be acknowledged using
PulsarMessageReceipt at any time before the ackTimeout occurs. | false | Boolean
| *camel.component.pulsar.auto-configuration* | The pulsar auto configuration.
The option is a org.apache.camel.component.pulsar.utils.AutoConfiguration type.
| | String
| *camel.component.pulsar.basic-property-binding* | Whether the component
should use basic property binding (Camel 2.x) or the newer property binding
with additional capabilities | false | Boolean
+| *camel.component.pulsar.batcher-builder* | Control batching method used by
the producer. The option is a org.apache.pulsar.client.api.BatcherBuilder type.
| | String
| *camel.component.pulsar.batching-enabled* | Control whether automatic
batching of messages is enabled for the producer. | true | Boolean
| *camel.component.pulsar.batching-max-messages* | The maximum size to batch
messages. | 1000 | Integer
| *camel.component.pulsar.batching-max-publish-delay-micros* | The maximum
time period within which the messages sent will be batched if batchingEnabled
is true. | 1000 | Long
@@ -56,6 +57,6 @@ The component supports 33 options, which are listed below.
| *camel.component.pulsar.send-timeout-ms* | Send timeout in milliseconds |
30000 | Integer
| *camel.component.pulsar.subscription-initial-position* | Control the initial
position in the topic of a newly created subscription. Default is latest
message. | | SubscriptionInitialPosition
| *camel.component.pulsar.subscription-name* | Name of the subscription to use
| subs | String
-| *camel.component.pulsar.subscription-type* | Type of the subscription
EXCLUSIVESHAREDFAILOVER, defaults to EXCLUSIVE | | SubscriptionType
+| *camel.component.pulsar.subscription-type* | Type of the subscription
EXCLUSIVESHAREDFAILOVERKEY_SHARED, defaults to EXCLUSIVE | | SubscriptionType
|===
// spring-boot-auto-configure options: END