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 16a5146 Regen
16a5146 is described below
commit 16a5146e22e30c752448a46cc7fb7799f9b763f0
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Oct 30 15:01:08 2020 +0100
Regen
---
.../apache/camel/springboot/catalog/components/pulsar.json | 2 ++
.../camel-pulsar-starter/src/main/docs/pulsar-starter.adoc | 3 ++-
.../pulsar/springboot/PulsarComponentConfiguration.java | 12 ++++++++++++
docs/modules/ROOT/pages/pulsar-starter.adoc | 3 ++-
4 files changed, 18 insertions(+), 2 deletions(-)
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 ca80836..29a0a50 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
@@ -34,6 +34,7 @@
"maxRedeliverCount": { "kind": "property", "displayName": "Max Redeliver
Count", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Maximum number of times that a message will be
redelivered before being sent to the dead letter queue. If this value is no
[...]
"negativeAckRedeliveryDelayMicros": { "kind": "property", "displayName":
"Negative Ack Redelivery Delay Micros", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "secret": false, "defaultValue": 60000000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Set the negative
acknowledgement delay" },
"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" },
+ "readCompacted": { "kind": "property", "displayName": "Read Compacted",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Enable compacted topic reading." },
"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" },
"subscriptionTopicsMode": { "kind": "property", "displayName":
"Subscription Topics Mode", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RegexSubscriptionMode", "enum": [
"PersistentOnly", "NonPersistentOnly", "AllTopics" ], "deprecated": false,
"secret": false, "defaultValue": "PersistentOnly", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration" [...]
@@ -74,6 +75,7 @@
"maxRedeliverCount": { "kind": "parameter", "displayName": "Max Redeliver
Count", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "secret":
false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Maximum number of times that a message
will be redelivered before being sent to the dead letter queue. If this valu
[...]
"negativeAckRedeliveryDelayMicros": { "kind": "parameter", "displayName":
"Negative Ack Redelivery Delay Micros", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "secret": false, "defaultValue": 60000000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Set the negative
acknowledgement delay" },
"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" },
+ "readCompacted": { "kind": "parameter", "displayName": "Read Compacted",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Enable compacted topic reading." },
"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" },
"subscriptionTopicsMode": { "kind": "parameter", "displayName":
"Subscription Topics Mode", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RegexSubscriptionMode", "enum": [
"PersistentOnly", "NonPersistentOnly", "AllTopics" ], "deprecated": false,
"secret": false, "defaultValue": "PersistentOnly", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfigu [...]
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 708f317..03d5363 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 36 options, which are listed below.
+The component supports 37 options, which are listed below.
@@ -53,6 +53,7 @@ The component supports 36 options, which are listed below.
| *camel.component.pulsar.producer-name* | Name of the producer. If unset,
lets Pulsar select a unique identifier. | | String
| *camel.component.pulsar.pulsar-client* | The pulsar client. The option is a
org.apache.pulsar.client.api.PulsarClient type. | | PulsarClient
| *camel.component.pulsar.pulsar-message-receipt-factory* | Provide a factory
to create an alternate implementation of PulsarMessageReceipt. The option is a
org.apache.camel.component.pulsar.PulsarMessageReceiptFactory type. | |
PulsarMessageReceiptFactory
+| *camel.component.pulsar.read-compacted* | Enable compacted topic reading. |
false | Boolean
| *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
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 6f03ed4..2331ffe 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
@@ -116,6 +116,10 @@ public class PulsarComponentConfiguration
*/
private Integer numberOfConsumers = 1;
/**
+ * Enable compacted topic reading.
+ */
+ private Boolean readCompacted = false;
+ /**
* Control the initial position in the topic of a newly created
* subscription. Default is latest message.
*/
@@ -333,6 +337,14 @@ public class PulsarComponentConfiguration
this.numberOfConsumers = numberOfConsumers;
}
+ public Boolean getReadCompacted() {
+ return readCompacted;
+ }
+
+ public void setReadCompacted(Boolean readCompacted) {
+ this.readCompacted = readCompacted;
+ }
+
public SubscriptionInitialPosition getSubscriptionInitialPosition() {
return subscriptionInitialPosition;
}
diff --git a/docs/modules/ROOT/pages/pulsar-starter.adoc
b/docs/modules/ROOT/pages/pulsar-starter.adoc
index 708f317..03d5363 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 36 options, which are listed below.
+The component supports 37 options, which are listed below.
@@ -53,6 +53,7 @@ The component supports 36 options, which are listed below.
| *camel.component.pulsar.producer-name* | Name of the producer. If unset,
lets Pulsar select a unique identifier. | | String
| *camel.component.pulsar.pulsar-client* | The pulsar client. The option is a
org.apache.pulsar.client.api.PulsarClient type. | | PulsarClient
| *camel.component.pulsar.pulsar-message-receipt-factory* | Provide a factory
to create an alternate implementation of PulsarMessageReceipt. The option is a
org.apache.camel.component.pulsar.PulsarMessageReceiptFactory type. | |
PulsarMessageReceiptFactory
+| *camel.component.pulsar.read-compacted* | Enable compacted topic reading. |
false | Boolean
| *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
