This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 4c5757e0673 CAMEL-19570: Change max.poll.interval.ms type from Long to
Integer to… (#10569)
4c5757e0673 is described below
commit 4c5757e067320673f2e760868c7a0f235934630e
Author: Alex <[email protected]>
AuthorDate: Wed Jul 5 10:13:57 2023 +0300
CAMEL-19570: Change max.poll.interval.ms type from Long to Integer to…
(#10569)
* CAMEL-19570: Change max.poll.interval.ms type from Long to Integer to be
inline with Kafka config types
* CAMEL-19570: Regenerate code
* CAMEL-19570: Revert unrelated changes
---
.../resources/org/apache/camel/catalog/components/kafka.json | 4 ++--
.../org/apache/camel/component/kafka/KafkaComponentConfigurer.java | 4 ++--
.../org/apache/camel/component/kafka/KafkaEndpointConfigurer.java | 4 ++--
.../generated/resources/org/apache/camel/component/kafka/kafka.json | 4 ++--
.../java/org/apache/camel/component/kafka/KafkaConfiguration.java | 6 +++---
.../camel/builder/component/dsl/KafkaComponentBuilderFactory.java | 6 +++---
.../camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java | 6 +++---
.../src/test/resources/json/test_component.json | 2 +-
8 files changed, 18 insertions(+), 18 deletions(-)
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 d257056c7bd..56b0c15611e 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
@@ -48,7 +48,7 @@
"heartbeatIntervalMs": { "index": 23, "kind": "property", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "3000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinato [...]
"keyDeserializer": { "index": 24, "kind": "property", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
[...]
"maxPartitionFetchBytes": { "index": 25, "kind": "property",
"displayName": "Max Partition Fetch Bytes", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server w [...]
- "maxPollIntervalMs": { "index": 26, "kind": "property", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This p [...]
+ "maxPollIntervalMs": { "index": 26, "kind": "property", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. Thi [...]
"maxPollRecords": { "index": 27, "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": { "index": 28, "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 [...]
"partitionAssignor": { "index": 29, "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 parti [...]
@@ -172,7 +172,7 @@
"heartbeatIntervalMs": { "index": 22, "kind": "parameter", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "3000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinat [...]
"keyDeserializer": { "index": 23, "kind": "parameter", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class fo
[...]
"maxPartitionFetchBytes": { "index": 24, "kind": "parameter",
"displayName": "Max Partition Fetch Bytes", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server [...]
- "maxPollIntervalMs": { "index": 25, "kind": "parameter", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This [...]
+ "maxPollIntervalMs": { "index": 25, "kind": "parameter", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. Th [...]
"maxPollRecords": { "index": 26, "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": { "index": 27, "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 t [...]
"partitionAssignor": { "index": 28, "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 part [...]
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 17a8e1fa68c..8fc0bf484fc 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
@@ -124,7 +124,7 @@ public class KafkaComponentConfigurer extends
PropertyConfigurerSupport implemen
case "maxpartitionfetchbytes":
case "maxPartitionFetchBytes":
getOrCreateConfiguration(target).setMaxPartitionFetchBytes(property(camelContext,
java.lang.Integer.class, value)); return true;
case "maxpollintervalms":
- case "maxPollIntervalMs":
getOrCreateConfiguration(target).setMaxPollIntervalMs(property(camelContext,
java.lang.Long.class, value)); return true;
+ case "maxPollIntervalMs":
getOrCreateConfiguration(target).setMaxPollIntervalMs(property(camelContext,
java.lang.Integer.class, value)); return true;
case "maxpollrecords":
case "maxPollRecords":
getOrCreateConfiguration(target).setMaxPollRecords(property(camelContext,
java.lang.Integer.class, value)); return true;
case "maxrequestsize":
@@ -346,7 +346,7 @@ public class KafkaComponentConfigurer extends
PropertyConfigurerSupport implemen
case "maxpartitionfetchbytes":
case "maxPartitionFetchBytes": return java.lang.Integer.class;
case "maxpollintervalms":
- case "maxPollIntervalMs": return java.lang.Long.class;
+ case "maxPollIntervalMs": return java.lang.Integer.class;
case "maxpollrecords":
case "maxPollRecords": return java.lang.Integer.class;
case "maxrequestsize":
diff --git
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
index 981619ad325..aa76beb09f8 100644
---
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
+++
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
@@ -114,7 +114,7 @@ public class KafkaEndpointConfigurer extends
PropertyConfigurerSupport implement
case "maxpartitionfetchbytes":
case "maxPartitionFetchBytes":
target.getConfiguration().setMaxPartitionFetchBytes(property(camelContext,
java.lang.Integer.class, value)); return true;
case "maxpollintervalms":
- case "maxPollIntervalMs":
target.getConfiguration().setMaxPollIntervalMs(property(camelContext,
java.lang.Long.class, value)); return true;
+ case "maxPollIntervalMs":
target.getConfiguration().setMaxPollIntervalMs(property(camelContext,
java.lang.Integer.class, value)); return true;
case "maxpollrecords":
case "maxPollRecords":
target.getConfiguration().setMaxPollRecords(property(camelContext,
java.lang.Integer.class, value)); return true;
case "maxrequestsize":
@@ -320,7 +320,7 @@ public class KafkaEndpointConfigurer extends
PropertyConfigurerSupport implement
case "maxpartitionfetchbytes":
case "maxPartitionFetchBytes": return java.lang.Integer.class;
case "maxpollintervalms":
- case "maxPollIntervalMs": return java.lang.Long.class;
+ case "maxPollIntervalMs": return java.lang.Integer.class;
case "maxpollrecords":
case "maxPollRecords": return java.lang.Integer.class;
case "maxrequestsize":
diff --git
a/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
b/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
index d257056c7bd..56b0c15611e 100644
---
a/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
+++
b/components/camel-kafka/src/generated/resources/org/apache/camel/component/kafka/kafka.json
@@ -48,7 +48,7 @@
"heartbeatIntervalMs": { "index": 23, "kind": "property", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "3000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinato [...]
"keyDeserializer": { "index": 24, "kind": "property", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
[...]
"maxPartitionFetchBytes": { "index": 25, "kind": "property",
"displayName": "Max Partition Fetch Bytes", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server w [...]
- "maxPollIntervalMs": { "index": 26, "kind": "property", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This p [...]
+ "maxPollIntervalMs": { "index": 26, "kind": "property", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. Thi [...]
"maxPollRecords": { "index": 27, "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": { "index": 28, "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 [...]
"partitionAssignor": { "index": 29, "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 parti [...]
@@ -172,7 +172,7 @@
"heartbeatIntervalMs": { "index": 22, "kind": "parameter", "displayName":
"Heartbeat Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "3000",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "The expected time
between heartbeats to the consumer coordinat [...]
"keyDeserializer": { "index": 23, "kind": "parameter", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class fo
[...]
"maxPartitionFetchBytes": { "index": 24, "kind": "parameter",
"displayName": "Max Partition Fetch Bytes", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1048576", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server [...]
- "maxPollIntervalMs": { "index": 25, "kind": "parameter", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Long", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This [...]
+ "maxPollIntervalMs": { "index": 25, "kind": "parameter", "displayName":
"Max Poll Interval Ms", "group": "consumer", "label": "consumer", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. Th [...]
"maxPollRecords": { "index": 26, "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": { "index": 27, "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 t [...]
"partitionAssignor": { "index": 28, "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 part [...]
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index e81007ffad9..82cc44d86c1 100755
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -110,7 +110,7 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
@UriParam(label = "consumer", defaultValue = "5000", javaType =
"java.time.Duration")
private Long pollTimeoutMs = 5000L;
@UriParam(label = "consumer", javaType = "java.time.Duration")
- private Long maxPollIntervalMs;
+ private Integer maxPollIntervalMs;
// auto.offset.reset1
@UriParam(label = "consumer", defaultValue = "latest", enums =
"latest,earliest,none")
private String autoOffsetReset = "latest";
@@ -1582,7 +1582,7 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
this.pollTimeoutMs = pollTimeoutMs;
}
- public Long getMaxPollIntervalMs() {
+ public Integer getMaxPollIntervalMs() {
return maxPollIntervalMs;
}
@@ -1592,7 +1592,7 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
* expiration of this timeout, then the consumer is considered failed and
the group will rebalance in order to
* reassign the partitions to another member.
*/
- public void setMaxPollIntervalMs(Long maxPollIntervalMs) {
+ public void setMaxPollIntervalMs(Integer maxPollIntervalMs) {
this.maxPollIntervalMs = maxPollIntervalMs;
}
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
index cde8be39ca5..bed5b8695d2 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java
@@ -547,7 +547,7 @@ public interface KafkaComponentBuilderFactory {
* considered failed and the group will rebalance in order to reassign
* the partitions to another member.
*
- * The option is a: <code>java.lang.Long</code> type.
+ * The option is a: <code>java.lang.Integer</code> type.
*
* Group: consumer
*
@@ -555,7 +555,7 @@ public interface KafkaComponentBuilderFactory {
* @return the dsl builder
*/
default KafkaComponentBuilder maxPollIntervalMs(
- java.lang.Long maxPollIntervalMs) {
+ java.lang.Integer maxPollIntervalMs) {
doSetProperty("maxPollIntervalMs", maxPollIntervalMs);
return this;
}
@@ -2163,7 +2163,7 @@ public interface KafkaComponentBuilderFactory {
case "heartbeatIntervalMs":
getOrCreateConfiguration((KafkaComponent)
component).setHeartbeatIntervalMs((java.lang.Integer) value); return true;
case "keyDeserializer": getOrCreateConfiguration((KafkaComponent)
component).setKeyDeserializer((java.lang.String) value); return true;
case "maxPartitionFetchBytes":
getOrCreateConfiguration((KafkaComponent)
component).setMaxPartitionFetchBytes((java.lang.Integer) value); return true;
- case "maxPollIntervalMs":
getOrCreateConfiguration((KafkaComponent)
component).setMaxPollIntervalMs((java.lang.Long) value); return true;
+ case "maxPollIntervalMs":
getOrCreateConfiguration((KafkaComponent)
component).setMaxPollIntervalMs((java.lang.Integer) value); return true;
case "maxPollRecords": getOrCreateConfiguration((KafkaComponent)
component).setMaxPollRecords((java.lang.Integer) value); return true;
case "offsetRepository": getOrCreateConfiguration((KafkaComponent)
component).setOffsetRepository((org.apache.camel.spi.StateRepository) value);
return true;
case "partitionAssignor":
getOrCreateConfiguration((KafkaComponent)
component).setPartitionAssignor((java.lang.String) value); return true;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
index 9103eab10a9..7ac6074c8e6 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
@@ -868,7 +868,7 @@ public interface KafkaEndpointBuilderFactory {
* considered failed and the group will rebalance in order to reassign
* the partitions to another member.
*
- * The option is a: <code>java.lang.Long</code> type.
+ * The option is a: <code>java.lang.Integer</code> type.
*
* Group: consumer
*
@@ -876,7 +876,7 @@ public interface KafkaEndpointBuilderFactory {
* @return the dsl builder
*/
default KafkaEndpointConsumerBuilder maxPollIntervalMs(
- Long maxPollIntervalMs) {
+ Integer maxPollIntervalMs) {
doSetProperty("maxPollIntervalMs", maxPollIntervalMs);
return this;
}
@@ -889,7 +889,7 @@ public interface KafkaEndpointBuilderFactory {
* the partitions to another member.
*
* The option will be converted to a
- * <code>java.lang.Long</code> type.
+ * <code>java.lang.Integer</code> type.
*
* Group: consumer
*
diff --git
a/tooling/maven/camel-package-maven-plugin/src/test/resources/json/test_component.json
b/tooling/maven/camel-package-maven-plugin/src/test/resources/json/test_component.json
index c04dba33ade..8fc577559bb 100644
---
a/tooling/maven/camel-package-maven-plugin/src/test/resources/json/test_component.json
+++
b/tooling/maven/camel-package-maven-plugin/src/test/resources/json/test_component.json
@@ -56,7 +56,7 @@
"kafkaHeaderDeserializer": { "kind": "parameter", "displayName": "Kafka
Header Deserializer", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer", "deprecated":
false, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Sets custom KafkaHeaderDeserializer for
deserialization kafka heade [...]
"keyDeserializer": { "kind": "parameter", "displayName": "Key
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
key that implements the Deseria [...]
"maxPartitionFetchBytes": { "kind": "parameter", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum amount of data per-partition the
server will return. The maximum total memo [...]
- "maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "java.lang.Long", "deprecated": false, "secret":
false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
amoun [...]
+ "maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The maximum delay between invocations of
poll() when using consumer group management. This places an upper bound on the
am [...]
"maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": 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, "secret": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The offset repository to use in order to
locally store the offset of each [...]
"partitionAssignor": { "kind": "parameter", "displayName": "Partition
Assignor", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": 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 assignment strategy that th [...]
