Skip to content

Commit 76b7f5c

Browse files
oscerdgithub-actions[bot]
oscerd
authored and
github-actions[bot]
committed
[create-pull-request] automated change
1 parent f043b41 commit 76b7f5c

File tree

41 files changed

+797
-61
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

41 files changed

+797
-61
lines changed

‎camel-kafka-connector-catalog/src/generated/resources/connectors/camel-https-sink.json

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,20 @@
6565
"priority": "MEDIUM",
6666
"required": "false"
6767
},
68+
"camel.sink.endpoint.multipartUpload": {
69+
"name": "camel.sink.endpoint.multipartUpload",
70+
"description": "Whether to force using multipart\/form-data for easy file uploads. This is only to be used for uploading the message body as a single entity form-data. For uploading multiple entries then use org.apache.hc.client5.http.entity.mime.MultipartEntityBuilder to build the form.",
71+
"defaultValue": "false",
72+
"priority": "MEDIUM",
73+
"required": "false"
74+
},
75+
"camel.sink.endpoint.multipartUploadName": {
76+
"name": "camel.sink.endpoint.multipartUploadName",
77+
"description": "The name of the multipart\/form-data when multipartUpload is enabled.",
78+
"defaultValue": "\"data\"",
79+
"priority": "MEDIUM",
80+
"required": "false"
81+
},
6882
"camel.sink.endpoint.skipRequestHeaders": {
6983
"name": "camel.sink.endpoint.skipRequestHeaders",
7084
"description": "Whether to skip mapping all the Camel headers as HTTP request headers. If there are no data from Camel headers needed to be included in the HTTP request then this can avoid parsing overhead with many object allocations for the JVM garbage collector.",

‎camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sjms2-sink.json

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -217,6 +217,19 @@
217217
"priority": "MEDIUM",
218218
"required": "false"
219219
},
220+
"camel.sink.endpoint.jmsMessageType": {
221+
"name": "camel.sink.endpoint.jmsMessageType",
222+
"description": "Allows you to force the use of a specific jakarta.jms.Message implementation for sending JMS messages. Possible values are: Bytes, Map, Object, Stream, Text. By default, Camel would determine which JMS message type to use from the In body type. This option allows you to specify it. One of: [Bytes] [Map] [Object] [Stream] [Text]",
223+
"priority": "MEDIUM",
224+
"required": "false",
225+
"enum": [
226+
"Bytes",
227+
"Map",
228+
"Object",
229+
"Stream",
230+
"Text"
231+
]
232+
},
220233
"camel.sink.endpoint.mapJmsMessage": {
221234
"name": "camel.sink.endpoint.mapJmsMessage",
222235
"description": "Specifies whether Camel should auto map the received JMS message to a suited payload type, such as jakarta.jms.TextMessage to a String etc. See section about how mapping works below for more details.",

‎camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sjms2-source.json

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,19 @@
220220
"priority": "MEDIUM",
221221
"required": "false"
222222
},
223+
"camel.source.endpoint.jmsMessageType": {
224+
"name": "camel.source.endpoint.jmsMessageType",
225+
"description": "Allows you to force the use of a specific jakarta.jms.Message implementation for sending JMS messages. Possible values are: Bytes, Map, Object, Stream, Text. By default, Camel would determine which JMS message type to use from the In body type. This option allows you to specify it. One of: [Bytes] [Map] [Object] [Stream] [Text]",
226+
"priority": "MEDIUM",
227+
"required": "false",
228+
"enum": [
229+
"Bytes",
230+
"Map",
231+
"Object",
232+
"Stream",
233+
"Text"
234+
]
235+
},
223236
"camel.source.endpoint.mapJmsMessage": {
224237
"name": "camel.source.endpoint.mapJmsMessage",
225238
"description": "Specifies whether Camel should auto map the received JMS message to a suited payload type, such as jakarta.jms.TextMessage to a String etc. See section about how mapping works below for more details.",

‎camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,7 @@ camel-oracle-database-sink-sink
161161
camel-oracle-database-source-source
162162
camel-postgresql-sink-sink
163163
camel-postgresql-source-source
164+
camel-pqc-signature-sink-sink
164165
camel-pulsar-sink-sink
165166
camel-pulsar-source-source
166167
camel-redis-sink-sink

‎connectors/camel-https-kafka-connector/src/generated/resources/camel-https-sink.json

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,20 @@
6565
"priority": "MEDIUM",
6666
"required": "false"
6767
},
68+
"camel.sink.endpoint.multipartUpload": {
69+
"name": "camel.sink.endpoint.multipartUpload",
70+
"description": "Whether to force using multipart\/form-data for easy file uploads. This is only to be used for uploading the message body as a single entity form-data. For uploading multiple entries then use org.apache.hc.client5.http.entity.mime.MultipartEntityBuilder to build the form.",
71+
"defaultValue": "false",
72+
"priority": "MEDIUM",
73+
"required": "false"
74+
},
75+
"camel.sink.endpoint.multipartUploadName": {
76+
"name": "camel.sink.endpoint.multipartUploadName",
77+
"description": "The name of the multipart\/form-data when multipartUpload is enabled.",
78+
"defaultValue": "\"data\"",
79+
"priority": "MEDIUM",
80+
"required": "false"
81+
},
6882
"camel.sink.endpoint.skipRequestHeaders": {
6983
"name": "camel.sink.endpoint.skipRequestHeaders",
7084
"description": "Whether to skip mapping all the Camel headers as HTTP request headers. If there are no data from Camel headers needed to be included in the HTTP request then this can avoid parsing overhead with many object allocations for the JVM garbage collector.",

‎connectors/camel-https-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/https/CamelHttpsSinkConnectorConfig.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,12 @@ public class CamelHttpsSinkConnectorConfig extends CamelSinkConnectorConfig {
4545
public static final String CAMEL_SINK_HTTPS_ENDPOINT_LOG_HTTP_ACTIVITY_CONF = "camel.sink.endpoint.logHttpActivity";
4646
public static final String CAMEL_SINK_HTTPS_ENDPOINT_LOG_HTTP_ACTIVITY_DOC = "To enable logging HTTP request and response. You can use a custom LoggingHttpActivityListener as httpActivityListener to control logging options.";
4747
public static final Boolean CAMEL_SINK_HTTPS_ENDPOINT_LOG_HTTP_ACTIVITY_DEFAULT = false;
48+
public static final String CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_CONF = "camel.sink.endpoint.multipartUpload";
49+
public static final String CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_DOC = "Whether to force using multipart/form-data for easy file uploads. This is only to be used for uploading the message body as a single entity form-data. For uploading multiple entries then use org.apache.hc.client5.http.entity.mime.MultipartEntityBuilder to build the form.";
50+
public static final Boolean CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_DEFAULT = false;
51+
public static final String CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_NAME_CONF = "camel.sink.endpoint.multipartUploadName";
52+
public static final String CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_NAME_DOC = "The name of the multipart/form-data when multipartUpload is enabled.";
53+
public static final String CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_NAME_DEFAULT = "data";
4854
public static final String CAMEL_SINK_HTTPS_ENDPOINT_SKIP_REQUEST_HEADERS_CONF = "camel.sink.endpoint.skipRequestHeaders";
4955
public static final String CAMEL_SINK_HTTPS_ENDPOINT_SKIP_REQUEST_HEADERS_DOC = "Whether to skip mapping all the Camel headers as HTTP request headers. If there are no data from Camel headers needed to be included in the HTTP request then this can avoid parsing overhead with many object allocations for the JVM garbage collector.";
5056
public static final Boolean CAMEL_SINK_HTTPS_ENDPOINT_SKIP_REQUEST_HEADERS_DEFAULT = false;
@@ -356,6 +362,8 @@ public static ConfigDef conf() {
356362
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_CONNECTION_CLOSE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_HTTPS_ENDPOINT_CONNECTION_CLOSE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_CONNECTION_CLOSE_DOC);
357363
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_HTTP_METHOD_CONF, ConfigDef.Type.STRING, CAMEL_SINK_HTTPS_ENDPOINT_HTTP_METHOD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_HTTP_METHOD_DOC);
358364
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_LOG_HTTP_ACTIVITY_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_HTTPS_ENDPOINT_LOG_HTTP_ACTIVITY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_LOG_HTTP_ACTIVITY_DOC);
365+
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_DOC);
366+
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_MULTIPART_UPLOAD_NAME_DOC);
359367
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_SKIP_REQUEST_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_HTTPS_ENDPOINT_SKIP_REQUEST_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_SKIP_REQUEST_HEADERS_DOC);
360368
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_SKIP_RESPONSE_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_HTTPS_ENDPOINT_SKIP_RESPONSE_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_SKIP_RESPONSE_HEADERS_DOC);
361369
conf.define(CAMEL_SINK_HTTPS_ENDPOINT_THROW_EXCEPTION_ON_FAILURE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_HTTPS_ENDPOINT_THROW_EXCEPTION_ON_FAILURE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_THROW_EXCEPTION_ON_FAILURE_DOC);

‎connectors/camel-jms-apache-artemis-sink-kafka-connector/pom.xml

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -49,15 +49,15 @@
4949
<groupId>org.apache.camel</groupId>
5050
<artifactId>camel-jms</artifactId>
5151
</dependency>
52-
<dependency>
53-
<groupId>org.apache.activemq</groupId>
54-
<artifactId>artemis-jakarta-client-all</artifactId>
55-
<version>2.40.0</version>
56-
</dependency>
5752
<dependency>
5853
<groupId>org.apache.camel</groupId>
5954
<artifactId>camel-yaml-dsl</artifactId>
6055
</dependency>
56+
<dependency>
57+
<groupId>org.apache.activemq</groupId>
58+
<artifactId>artemis-jakarta-client-all</artifactId>
59+
<version>2.41.0</version>
60+
</dependency>
6161
<dependency>
6262
<groupId>org.apache.camel</groupId>
6363
<artifactId>camel-kamelet</artifactId>

‎connectors/camel-jms-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ spec:
5555
dependencies:
5656
- "camel:jms"
5757
- "camel:kamelet"
58-
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.40.0"
58+
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.41.0"
5959
template:
6060
beans:
6161
- name: connectionFactoryBean

‎connectors/camel-jms-apache-artemis-source-kafka-connector/pom.xml

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -49,15 +49,15 @@
4949
<groupId>org.apache.camel</groupId>
5050
<artifactId>camel-jms</artifactId>
5151
</dependency>
52-
<dependency>
53-
<groupId>org.apache.activemq</groupId>
54-
<artifactId>artemis-jakarta-client-all</artifactId>
55-
<version>2.40.0</version>
56-
</dependency>
5752
<dependency>
5853
<groupId>org.apache.camel</groupId>
5954
<artifactId>camel-yaml-dsl</artifactId>
6055
</dependency>
56+
<dependency>
57+
<groupId>org.apache.activemq</groupId>
58+
<artifactId>artemis-jakarta-client-all</artifactId>
59+
<version>2.41.0</version>
60+
</dependency>
6161
<dependency>
6262
<groupId>org.apache.camel</groupId>
6363
<artifactId>camel-kamelet</artifactId>

‎connectors/camel-jms-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ spec:
5454
dependencies:
5555
- "camel:jms"
5656
- "camel:kamelet"
57-
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.40.0"
57+
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.41.0"
5858
template:
5959
beans:
6060
- name: connectionFactoryBean

‎connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/pom.xml

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -54,15 +54,15 @@
5454
<groupId>org.apache.camel</groupId>
5555
<artifactId>camel-jms</artifactId>
5656
</dependency>
57-
<dependency>
58-
<groupId>org.apache.activemq</groupId>
59-
<artifactId>artemis-jakarta-client-all</artifactId>
60-
<version>2.40.0</version>
61-
</dependency>
6257
<dependency>
6358
<groupId>org.apache.camel</groupId>
6459
<artifactId>camel-yaml-dsl</artifactId>
6560
</dependency>
61+
<dependency>
62+
<groupId>org.apache.activemq</groupId>
63+
<artifactId>artemis-jakarta-client-all</artifactId>
64+
<version>2.41.0</version>
65+
</dependency>
6666
<dependency>
6767
<groupId>org.apache.camel</groupId>
6868
<artifactId>camel-kamelet</artifactId>

‎connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -71,22 +71,22 @@ spec:
7171
maxSessionsPerConnection:
7272
title: "Max Sessions Per Connection"
7373
description: "The maximum number of pooled sessions per connection in the pool"
74-
type: int
74+
type: integer
7575
default: 500
7676
maxIdleSessionsPerConnection:
7777
title: "Max Idle Sessions Per Connection"
7878
description: "The number of idle sessions allowed per connection before they are closed."
79-
type: int
79+
type: integer
8080
default: 500
8181
connectionIdleTimeout:
8282
title: "Connection Idle Timeout"
8383
description: "The maximum time a pooled Connection can sit unused before it is eligible for removal (in milliseconds)"
84-
type: int
84+
type: integer
8585
default: 30000
8686
dependencies:
8787
- "camel:jms"
8888
- "camel:kamelet"
89-
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.40.0"
89+
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.41.0"
9090
- "mvn:org.messaginghub:pooled-jms:3.1.7"
9191
template:
9292
beans:

‎connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/pom.xml

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -54,15 +54,15 @@
5454
<groupId>org.apache.camel</groupId>
5555
<artifactId>camel-jms</artifactId>
5656
</dependency>
57-
<dependency>
58-
<groupId>org.apache.activemq</groupId>
59-
<artifactId>artemis-jakarta-client-all</artifactId>
60-
<version>2.40.0</version>
61-
</dependency>
6257
<dependency>
6358
<groupId>org.apache.camel</groupId>
6459
<artifactId>camel-yaml-dsl</artifactId>
6560
</dependency>
61+
<dependency>
62+
<groupId>org.apache.activemq</groupId>
63+
<artifactId>artemis-jakarta-client-all</artifactId>
64+
<version>2.41.0</version>
65+
</dependency>
6666
<dependency>
6767
<groupId>org.apache.camel</groupId>
6868
<artifactId>camel-kamelet</artifactId>

‎connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -70,22 +70,22 @@ spec:
7070
maxSessionsPerConnection:
7171
title: "Max Session Per Connection"
7272
description: "The maximum number of pooled sessions per connection in the pool"
73-
type: int
73+
type: integer
7474
default: 500
7575
maxIdleSessionsPerConnection:
7676
title: "Max Idle Sessions Per Connection"
7777
description: "The number of idle sessions allowed per connection before they are closed."
78-
type: int
78+
type: integer
7979
default: 500
8080
connectionIdleTimeout:
8181
title: "Connection Idle Timeout"
8282
description: "The maximum time a pooled Connection can sit unused before it is eligible for removal (in milliseconds)"
83-
type: int
83+
type: integer
8484
default: 30000
8585
dependencies:
8686
- "camel:jms"
8787
- "camel:kamelet"
88-
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.40.0"
88+
- "mvn:org.apache.activemq:artemis-jakarta-client-all:2.41.0"
8989
- "mvn:org.messaginghub:pooled-jms:3.1.7"
9090
template:
9191
beans:

‎connectors/camel-kafka-batch-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -108,21 +108,21 @@ spec:
108108
batchSize:
109109
title: Batch Dimension
110110
description: The maximum number of records returned in a single call to poll()
111-
type: int
111+
type: integer
112112
default: 500
113113
pollTimeout:
114114
title: Poll Timeout Interval
115115
description: The timeout used when polling the KafkaConsumer
116-
type: int
116+
type: integer
117117
default: 5000
118118
maxPollIntervalMs:
119119
title: Max Poll Interval
120120
description: The maximum delay between invocations of poll() when using consumer group management
121-
type: int
121+
type: integer
122122
batchingIntervalMs:
123123
title: Batching Interval
124124
description: In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).
125-
type: int
125+
type: integer
126126
topicIsPattern:
127127
title: Topic Is Pattern
128128
description: Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.

‎connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -114,21 +114,21 @@ spec:
114114
batchSize:
115115
title: Batch Dimension
116116
description: The maximum number of records returned in a single call to poll()
117-
type: int
117+
type: integer
118118
default: 500
119119
pollTimeout:
120120
title: Poll Timeout Interval
121121
description: The timeout used when polling the KafkaConsumer
122-
type: int
122+
type: integer
123123
default: 5000
124124
maxPollIntervalMs:
125125
title: Max Poll Interval
126126
description: The maximum delay between invocations of poll() when using consumer group management
127-
type: int
127+
type: integer
128128
batchingIntervalMs:
129129
title: Batching Interval
130130
description: In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).
131-
type: int
131+
type: integer
132132
apicurioAuthServiceUrl:
133133
title: Apicurio Registry Auth Service URL
134134
description: The URL for Keycloak instance securing the Apicurio Registry

‎connectors/camel-kafka-batch-azure-schema-registry-source-kafka-connector/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -128,21 +128,21 @@ spec:
128128
batchSize:
129129
title: Batch Dimension
130130
description: The maximum number of records returned in a single call to poll()
131-
type: int
131+
type: integer
132132
default: 500
133133
pollTimeout:
134134
title: Poll Timeout Interval
135135
description: The timeout used when polling the KafkaConsumer
136-
type: int
136+
type: integer
137137
default: 5000
138138
maxPollIntervalMs:
139139
title: Max Poll Interval
140140
description: The maximum delay between invocations of poll() when using consumer group management
141-
type: int
141+
type: integer
142142
batchingIntervalMs:
143143
title: Batching Interval
144144
description: In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).
145-
type: int
145+
type: integer
146146
topicIsPattern:
147147
title: Topic Is Pattern
148148
description: Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.

‎connectors/camel-kafka-batch-not-secured-source-kafka-connector/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -90,21 +90,21 @@ spec:
9090
batchSize:
9191
title: Batch Dimension
9292
description: The maximum number of records returned in a single call to poll()
93-
type: int
93+
type: integer
9494
default: 500
9595
pollTimeout:
9696
title: Poll Timeout Interval
9797
description: The timeout used when polling the KafkaConsumer
98-
type: int
98+
type: integer
9999
default: 5000
100100
maxPollIntervalMs:
101101
title: Max Poll Interval
102102
description: The maximum delay between invocations of poll() when using consumer group management
103-
type: int
103+
type: integer
104104
batchingIntervalMs:
105105
title: Batching Interval
106106
description: In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).
107-
type: int
107+
type: integer
108108
topicIsPattern:
109109
title: Topic Is Pattern
110110
description: Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.

‎connectors/camel-kafka-batch-scram-source-kafka-connector/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -121,21 +121,21 @@ spec:
121121
batchSize:
122122
title: Batch Dimension
123123
description: The maximum number of records returned in a single call to poll()
124-
type: int
124+
type: integer
125125
default: 500
126126
pollTimeout:
127127
title: Poll Timeout Interval
128128
description: The timeout used when polling the KafkaConsumer
129-
type: int
129+
type: integer
130130
default: 5000
131131
maxPollIntervalMs:
132132
title: Max Poll Interval
133133
description: The maximum delay between invocations of poll() when using consumer group management
134-
type: int
134+
type: integer
135135
batchingIntervalMs:
136136
title: Batching Interval
137137
description: In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).
138-
type: int
138+
type: integer
139139
topicIsPattern:
140140
title: Topic Is Pattern
141141
description: Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.

0 commit comments

Comments
 (0)