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 836ad38 CAMEL-17284: upgrade Kafka clients to 3.1.0
836ad38 is described below
commit 836ad38e8d658642caa93d32300c6d320d05d2aa
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Jan 28 14:48:05 2022 +0100
CAMEL-17284: upgrade Kafka clients to 3.1.0
---
.../vertx/kafka/VertxKafkaComponentConfigurer.java | 84 -----
.../vertx/kafka/VertxKafkaEndpointConfigurer.java | 84 -----
.../vertx/kafka/VertxKafkaEndpointUriFactory.java | 16 +-
.../configuration/VertxKafkaConfiguration.java | 354 ++-------------------
.../camel/component/vertx/kafka/vertx-kafka.json | 64 ++--
components/camel-vertx/camel-vertx-kafka/pom.xml | 12 +
parent/pom.xml | 1 +
7 files changed, 58 insertions(+), 557 deletions(-)
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentConfigurer.java
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentConfigurer.java
index 86e7864..e6f9cf4 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentConfigurer.java
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentConfigurer.java
@@ -159,10 +159,6 @@ public class VertxKafkaComponentConfigurer extends
PropertyConfigurerSupport imp
case "saslLoginCallbackHandlerClass":
getOrCreateConfiguration(target).setSaslLoginCallbackHandlerClass(property(camelContext,
java.lang.String.class, value)); return true;
case "saslloginclass":
case "saslLoginClass":
getOrCreateConfiguration(target).setSaslLoginClass(property(camelContext,
java.lang.String.class, value)); return true;
- case "saslloginconnecttimeoutms":
- case "saslLoginConnectTimeoutMs":
getOrCreateConfiguration(target).setSaslLoginConnectTimeoutMs(property(camelContext,
java.lang.Integer.class, value)); return true;
- case "saslloginreadtimeoutms":
- case "saslLoginReadTimeoutMs":
getOrCreateConfiguration(target).setSaslLoginReadTimeoutMs(property(camelContext,
java.lang.Integer.class, value)); return true;
case "saslloginrefreshbufferseconds":
case "saslLoginRefreshBufferSeconds":
getOrCreateConfiguration(target).setSaslLoginRefreshBufferSeconds(property(camelContext,
short.class, value)); return true;
case "saslloginrefreshminperiodseconds":
@@ -171,32 +167,8 @@ public class VertxKafkaComponentConfigurer extends
PropertyConfigurerSupport imp
case "saslLoginRefreshWindowFactor":
getOrCreateConfiguration(target).setSaslLoginRefreshWindowFactor(property(camelContext,
double.class, value)); return true;
case "saslloginrefreshwindowjitter":
case "saslLoginRefreshWindowJitter":
getOrCreateConfiguration(target).setSaslLoginRefreshWindowJitter(property(camelContext,
double.class, value)); return true;
- case "saslloginretrybackoffmaxms":
- case "saslLoginRetryBackoffMaxMs":
getOrCreateConfiguration(target).setSaslLoginRetryBackoffMaxMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "saslloginretrybackoffms":
- case "saslLoginRetryBackoffMs":
getOrCreateConfiguration(target).setSaslLoginRetryBackoffMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
case "saslmechanism":
case "saslMechanism":
getOrCreateConfiguration(target).setSaslMechanism(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerclockskewseconds":
- case "saslOauthbearerClockSkewSeconds":
getOrCreateConfiguration(target).setSaslOauthbearerClockSkewSeconds(property(camelContext,
int.class, value)); return true;
- case "sasloauthbearerexpectedaudience":
- case "saslOauthbearerExpectedAudience":
getOrCreateConfiguration(target).setSaslOauthbearerExpectedAudience(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerexpectedissuer":
- case "saslOauthbearerExpectedIssuer":
getOrCreateConfiguration(target).setSaslOauthbearerExpectedIssuer(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerjwksendpointrefreshms":
- case "saslOauthbearerJwksEndpointRefreshMs":
getOrCreateConfiguration(target).setSaslOauthbearerJwksEndpointRefreshMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "sasloauthbearerjwksendpointretrybackoffmaxms":
- case "saslOauthbearerJwksEndpointRetryBackoffMaxMs":
getOrCreateConfiguration(target).setSaslOauthbearerJwksEndpointRetryBackoffMaxMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "sasloauthbearerjwksendpointretrybackoffms":
- case "saslOauthbearerJwksEndpointRetryBackoffMs":
getOrCreateConfiguration(target).setSaslOauthbearerJwksEndpointRetryBackoffMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "sasloauthbearerjwksendpointurl":
- case "saslOauthbearerJwksEndpointUrl":
getOrCreateConfiguration(target).setSaslOauthbearerJwksEndpointUrl(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerscopeclaimname":
- case "saslOauthbearerScopeClaimName":
getOrCreateConfiguration(target).setSaslOauthbearerScopeClaimName(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearersubclaimname":
- case "saslOauthbearerSubClaimName":
getOrCreateConfiguration(target).setSaslOauthbearerSubClaimName(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearertokenendpointurl":
- case "saslOauthbearerTokenEndpointUrl":
getOrCreateConfiguration(target).setSaslOauthbearerTokenEndpointUrl(property(camelContext,
java.lang.String.class, value)); return true;
case "securityprotocol":
case "securityProtocol":
getOrCreateConfiguration(target).setSecurityProtocol(property(camelContext,
java.lang.String.class, value)); return true;
case "securityproviders":
@@ -407,10 +379,6 @@ public class VertxKafkaComponentConfigurer extends
PropertyConfigurerSupport imp
case "saslLoginCallbackHandlerClass": return java.lang.String.class;
case "saslloginclass":
case "saslLoginClass": return java.lang.String.class;
- case "saslloginconnecttimeoutms":
- case "saslLoginConnectTimeoutMs": return java.lang.Integer.class;
- case "saslloginreadtimeoutms":
- case "saslLoginReadTimeoutMs": return java.lang.Integer.class;
case "saslloginrefreshbufferseconds":
case "saslLoginRefreshBufferSeconds": return short.class;
case "saslloginrefreshminperiodseconds":
@@ -419,32 +387,8 @@ public class VertxKafkaComponentConfigurer extends
PropertyConfigurerSupport imp
case "saslLoginRefreshWindowFactor": return double.class;
case "saslloginrefreshwindowjitter":
case "saslLoginRefreshWindowJitter": return double.class;
- case "saslloginretrybackoffmaxms":
- case "saslLoginRetryBackoffMaxMs": return long.class;
- case "saslloginretrybackoffms":
- case "saslLoginRetryBackoffMs": return long.class;
case "saslmechanism":
case "saslMechanism": return java.lang.String.class;
- case "sasloauthbearerclockskewseconds":
- case "saslOauthbearerClockSkewSeconds": return int.class;
- case "sasloauthbearerexpectedaudience":
- case "saslOauthbearerExpectedAudience": return java.lang.String.class;
- case "sasloauthbearerexpectedissuer":
- case "saslOauthbearerExpectedIssuer": return java.lang.String.class;
- case "sasloauthbearerjwksendpointrefreshms":
- case "saslOauthbearerJwksEndpointRefreshMs": return long.class;
- case "sasloauthbearerjwksendpointretrybackoffmaxms":
- case "saslOauthbearerJwksEndpointRetryBackoffMaxMs": return long.class;
- case "sasloauthbearerjwksendpointretrybackoffms":
- case "saslOauthbearerJwksEndpointRetryBackoffMs": return long.class;
- case "sasloauthbearerjwksendpointurl":
- case "saslOauthbearerJwksEndpointUrl": return java.lang.String.class;
- case "sasloauthbearerscopeclaimname":
- case "saslOauthbearerScopeClaimName": return java.lang.String.class;
- case "sasloauthbearersubclaimname":
- case "saslOauthbearerSubClaimName": return java.lang.String.class;
- case "sasloauthbearertokenendpointurl":
- case "saslOauthbearerTokenEndpointUrl": return java.lang.String.class;
case "securityprotocol":
case "securityProtocol": return java.lang.String.class;
case "securityproviders":
@@ -651,10 +595,6 @@ public class VertxKafkaComponentConfigurer extends
PropertyConfigurerSupport imp
case "saslLoginCallbackHandlerClass": return
getOrCreateConfiguration(target).getSaslLoginCallbackHandlerClass();
case "saslloginclass":
case "saslLoginClass": return
getOrCreateConfiguration(target).getSaslLoginClass();
- case "saslloginconnecttimeoutms":
- case "saslLoginConnectTimeoutMs": return
getOrCreateConfiguration(target).getSaslLoginConnectTimeoutMs();
- case "saslloginreadtimeoutms":
- case "saslLoginReadTimeoutMs": return
getOrCreateConfiguration(target).getSaslLoginReadTimeoutMs();
case "saslloginrefreshbufferseconds":
case "saslLoginRefreshBufferSeconds": return
getOrCreateConfiguration(target).getSaslLoginRefreshBufferSeconds();
case "saslloginrefreshminperiodseconds":
@@ -663,32 +603,8 @@ public class VertxKafkaComponentConfigurer extends
PropertyConfigurerSupport imp
case "saslLoginRefreshWindowFactor": return
getOrCreateConfiguration(target).getSaslLoginRefreshWindowFactor();
case "saslloginrefreshwindowjitter":
case "saslLoginRefreshWindowJitter": return
getOrCreateConfiguration(target).getSaslLoginRefreshWindowJitter();
- case "saslloginretrybackoffmaxms":
- case "saslLoginRetryBackoffMaxMs": return
getOrCreateConfiguration(target).getSaslLoginRetryBackoffMaxMs();
- case "saslloginretrybackoffms":
- case "saslLoginRetryBackoffMs": return
getOrCreateConfiguration(target).getSaslLoginRetryBackoffMs();
case "saslmechanism":
case "saslMechanism": return
getOrCreateConfiguration(target).getSaslMechanism();
- case "sasloauthbearerclockskewseconds":
- case "saslOauthbearerClockSkewSeconds": return
getOrCreateConfiguration(target).getSaslOauthbearerClockSkewSeconds();
- case "sasloauthbearerexpectedaudience":
- case "saslOauthbearerExpectedAudience": return
getOrCreateConfiguration(target).getSaslOauthbearerExpectedAudience();
- case "sasloauthbearerexpectedissuer":
- case "saslOauthbearerExpectedIssuer": return
getOrCreateConfiguration(target).getSaslOauthbearerExpectedIssuer();
- case "sasloauthbearerjwksendpointrefreshms":
- case "saslOauthbearerJwksEndpointRefreshMs": return
getOrCreateConfiguration(target).getSaslOauthbearerJwksEndpointRefreshMs();
- case "sasloauthbearerjwksendpointretrybackoffmaxms":
- case "saslOauthbearerJwksEndpointRetryBackoffMaxMs": return
getOrCreateConfiguration(target).getSaslOauthbearerJwksEndpointRetryBackoffMaxMs();
- case "sasloauthbearerjwksendpointretrybackoffms":
- case "saslOauthbearerJwksEndpointRetryBackoffMs": return
getOrCreateConfiguration(target).getSaslOauthbearerJwksEndpointRetryBackoffMs();
- case "sasloauthbearerjwksendpointurl":
- case "saslOauthbearerJwksEndpointUrl": return
getOrCreateConfiguration(target).getSaslOauthbearerJwksEndpointUrl();
- case "sasloauthbearerscopeclaimname":
- case "saslOauthbearerScopeClaimName": return
getOrCreateConfiguration(target).getSaslOauthbearerScopeClaimName();
- case "sasloauthbearersubclaimname":
- case "saslOauthbearerSubClaimName": return
getOrCreateConfiguration(target).getSaslOauthbearerSubClaimName();
- case "sasloauthbearertokenendpointurl":
- case "saslOauthbearerTokenEndpointUrl": return
getOrCreateConfiguration(target).getSaslOauthbearerTokenEndpointUrl();
case "securityprotocol":
case "securityProtocol": return
getOrCreateConfiguration(target).getSecurityProtocol();
case "securityproviders":
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointConfigurer.java
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointConfigurer.java
index 8187e29..42c8dac 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointConfigurer.java
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointConfigurer.java
@@ -151,10 +151,6 @@ public class VertxKafkaEndpointConfigurer extends
PropertyConfigurerSupport impl
case "saslLoginCallbackHandlerClass":
target.getConfiguration().setSaslLoginCallbackHandlerClass(property(camelContext,
java.lang.String.class, value)); return true;
case "saslloginclass":
case "saslLoginClass":
target.getConfiguration().setSaslLoginClass(property(camelContext,
java.lang.String.class, value)); return true;
- case "saslloginconnecttimeoutms":
- case "saslLoginConnectTimeoutMs":
target.getConfiguration().setSaslLoginConnectTimeoutMs(property(camelContext,
java.lang.Integer.class, value)); return true;
- case "saslloginreadtimeoutms":
- case "saslLoginReadTimeoutMs":
target.getConfiguration().setSaslLoginReadTimeoutMs(property(camelContext,
java.lang.Integer.class, value)); return true;
case "saslloginrefreshbufferseconds":
case "saslLoginRefreshBufferSeconds":
target.getConfiguration().setSaslLoginRefreshBufferSeconds(property(camelContext,
short.class, value)); return true;
case "saslloginrefreshminperiodseconds":
@@ -163,32 +159,8 @@ public class VertxKafkaEndpointConfigurer extends
PropertyConfigurerSupport impl
case "saslLoginRefreshWindowFactor":
target.getConfiguration().setSaslLoginRefreshWindowFactor(property(camelContext,
double.class, value)); return true;
case "saslloginrefreshwindowjitter":
case "saslLoginRefreshWindowJitter":
target.getConfiguration().setSaslLoginRefreshWindowJitter(property(camelContext,
double.class, value)); return true;
- case "saslloginretrybackoffmaxms":
- case "saslLoginRetryBackoffMaxMs":
target.getConfiguration().setSaslLoginRetryBackoffMaxMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "saslloginretrybackoffms":
- case "saslLoginRetryBackoffMs":
target.getConfiguration().setSaslLoginRetryBackoffMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
case "saslmechanism":
case "saslMechanism":
target.getConfiguration().setSaslMechanism(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerclockskewseconds":
- case "saslOauthbearerClockSkewSeconds":
target.getConfiguration().setSaslOauthbearerClockSkewSeconds(property(camelContext,
int.class, value)); return true;
- case "sasloauthbearerexpectedaudience":
- case "saslOauthbearerExpectedAudience":
target.getConfiguration().setSaslOauthbearerExpectedAudience(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerexpectedissuer":
- case "saslOauthbearerExpectedIssuer":
target.getConfiguration().setSaslOauthbearerExpectedIssuer(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerjwksendpointrefreshms":
- case "saslOauthbearerJwksEndpointRefreshMs":
target.getConfiguration().setSaslOauthbearerJwksEndpointRefreshMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "sasloauthbearerjwksendpointretrybackoffmaxms":
- case "saslOauthbearerJwksEndpointRetryBackoffMaxMs":
target.getConfiguration().setSaslOauthbearerJwksEndpointRetryBackoffMaxMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "sasloauthbearerjwksendpointretrybackoffms":
- case "saslOauthbearerJwksEndpointRetryBackoffMs":
target.getConfiguration().setSaslOauthbearerJwksEndpointRetryBackoffMs(property(camelContext,
java.time.Duration.class, value).toMillis()); return true;
- case "sasloauthbearerjwksendpointurl":
- case "saslOauthbearerJwksEndpointUrl":
target.getConfiguration().setSaslOauthbearerJwksEndpointUrl(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearerscopeclaimname":
- case "saslOauthbearerScopeClaimName":
target.getConfiguration().setSaslOauthbearerScopeClaimName(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearersubclaimname":
- case "saslOauthbearerSubClaimName":
target.getConfiguration().setSaslOauthbearerSubClaimName(property(camelContext,
java.lang.String.class, value)); return true;
- case "sasloauthbearertokenendpointurl":
- case "saslOauthbearerTokenEndpointUrl":
target.getConfiguration().setSaslOauthbearerTokenEndpointUrl(property(camelContext,
java.lang.String.class, value)); return true;
case "securityprotocol":
case "securityProtocol":
target.getConfiguration().setSecurityProtocol(property(camelContext,
java.lang.String.class, value)); return true;
case "securityproviders":
@@ -388,10 +360,6 @@ public class VertxKafkaEndpointConfigurer extends
PropertyConfigurerSupport impl
case "saslLoginCallbackHandlerClass": return java.lang.String.class;
case "saslloginclass":
case "saslLoginClass": return java.lang.String.class;
- case "saslloginconnecttimeoutms":
- case "saslLoginConnectTimeoutMs": return java.lang.Integer.class;
- case "saslloginreadtimeoutms":
- case "saslLoginReadTimeoutMs": return java.lang.Integer.class;
case "saslloginrefreshbufferseconds":
case "saslLoginRefreshBufferSeconds": return short.class;
case "saslloginrefreshminperiodseconds":
@@ -400,32 +368,8 @@ public class VertxKafkaEndpointConfigurer extends
PropertyConfigurerSupport impl
case "saslLoginRefreshWindowFactor": return double.class;
case "saslloginrefreshwindowjitter":
case "saslLoginRefreshWindowJitter": return double.class;
- case "saslloginretrybackoffmaxms":
- case "saslLoginRetryBackoffMaxMs": return long.class;
- case "saslloginretrybackoffms":
- case "saslLoginRetryBackoffMs": return long.class;
case "saslmechanism":
case "saslMechanism": return java.lang.String.class;
- case "sasloauthbearerclockskewseconds":
- case "saslOauthbearerClockSkewSeconds": return int.class;
- case "sasloauthbearerexpectedaudience":
- case "saslOauthbearerExpectedAudience": return java.lang.String.class;
- case "sasloauthbearerexpectedissuer":
- case "saslOauthbearerExpectedIssuer": return java.lang.String.class;
- case "sasloauthbearerjwksendpointrefreshms":
- case "saslOauthbearerJwksEndpointRefreshMs": return long.class;
- case "sasloauthbearerjwksendpointretrybackoffmaxms":
- case "saslOauthbearerJwksEndpointRetryBackoffMaxMs": return long.class;
- case "sasloauthbearerjwksendpointretrybackoffms":
- case "saslOauthbearerJwksEndpointRetryBackoffMs": return long.class;
- case "sasloauthbearerjwksendpointurl":
- case "saslOauthbearerJwksEndpointUrl": return java.lang.String.class;
- case "sasloauthbearerscopeclaimname":
- case "saslOauthbearerScopeClaimName": return java.lang.String.class;
- case "sasloauthbearersubclaimname":
- case "saslOauthbearerSubClaimName": return java.lang.String.class;
- case "sasloauthbearertokenendpointurl":
- case "saslOauthbearerTokenEndpointUrl": return java.lang.String.class;
case "securityprotocol":
case "securityProtocol": return java.lang.String.class;
case "securityproviders":
@@ -626,10 +570,6 @@ public class VertxKafkaEndpointConfigurer extends
PropertyConfigurerSupport impl
case "saslLoginCallbackHandlerClass": return
target.getConfiguration().getSaslLoginCallbackHandlerClass();
case "saslloginclass":
case "saslLoginClass": return
target.getConfiguration().getSaslLoginClass();
- case "saslloginconnecttimeoutms":
- case "saslLoginConnectTimeoutMs": return
target.getConfiguration().getSaslLoginConnectTimeoutMs();
- case "saslloginreadtimeoutms":
- case "saslLoginReadTimeoutMs": return
target.getConfiguration().getSaslLoginReadTimeoutMs();
case "saslloginrefreshbufferseconds":
case "saslLoginRefreshBufferSeconds": return
target.getConfiguration().getSaslLoginRefreshBufferSeconds();
case "saslloginrefreshminperiodseconds":
@@ -638,32 +578,8 @@ public class VertxKafkaEndpointConfigurer extends
PropertyConfigurerSupport impl
case "saslLoginRefreshWindowFactor": return
target.getConfiguration().getSaslLoginRefreshWindowFactor();
case "saslloginrefreshwindowjitter":
case "saslLoginRefreshWindowJitter": return
target.getConfiguration().getSaslLoginRefreshWindowJitter();
- case "saslloginretrybackoffmaxms":
- case "saslLoginRetryBackoffMaxMs": return
target.getConfiguration().getSaslLoginRetryBackoffMaxMs();
- case "saslloginretrybackoffms":
- case "saslLoginRetryBackoffMs": return
target.getConfiguration().getSaslLoginRetryBackoffMs();
case "saslmechanism":
case "saslMechanism": return
target.getConfiguration().getSaslMechanism();
- case "sasloauthbearerclockskewseconds":
- case "saslOauthbearerClockSkewSeconds": return
target.getConfiguration().getSaslOauthbearerClockSkewSeconds();
- case "sasloauthbearerexpectedaudience":
- case "saslOauthbearerExpectedAudience": return
target.getConfiguration().getSaslOauthbearerExpectedAudience();
- case "sasloauthbearerexpectedissuer":
- case "saslOauthbearerExpectedIssuer": return
target.getConfiguration().getSaslOauthbearerExpectedIssuer();
- case "sasloauthbearerjwksendpointrefreshms":
- case "saslOauthbearerJwksEndpointRefreshMs": return
target.getConfiguration().getSaslOauthbearerJwksEndpointRefreshMs();
- case "sasloauthbearerjwksendpointretrybackoffmaxms":
- case "saslOauthbearerJwksEndpointRetryBackoffMaxMs": return
target.getConfiguration().getSaslOauthbearerJwksEndpointRetryBackoffMaxMs();
- case "sasloauthbearerjwksendpointretrybackoffms":
- case "saslOauthbearerJwksEndpointRetryBackoffMs": return
target.getConfiguration().getSaslOauthbearerJwksEndpointRetryBackoffMs();
- case "sasloauthbearerjwksendpointurl":
- case "saslOauthbearerJwksEndpointUrl": return
target.getConfiguration().getSaslOauthbearerJwksEndpointUrl();
- case "sasloauthbearerscopeclaimname":
- case "saslOauthbearerScopeClaimName": return
target.getConfiguration().getSaslOauthbearerScopeClaimName();
- case "sasloauthbearersubclaimname":
- case "saslOauthbearerSubClaimName": return
target.getConfiguration().getSaslOauthbearerSubClaimName();
- case "sasloauthbearertokenendpointurl":
- case "saslOauthbearerTokenEndpointUrl": return
target.getConfiguration().getSaslOauthbearerTokenEndpointUrl();
case "securityprotocol":
case "securityProtocol": return
target.getConfiguration().getSecurityProtocol();
case "securityproviders":
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointUriFactory.java
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointUriFactory.java
index faba4c1..7d4445b 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointUriFactory.java
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/VertxKafkaEndpointUriFactory.java
@@ -21,14 +21,12 @@ public class VertxKafkaEndpointUriFactory extends
org.apache.camel.support.compo
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(117);
+ Set<String> props = new HashSet<>(103);
props.add("allowManualCommit");
props.add("receiveBufferBytes");
props.add("saslLoginRefreshWindowFactor");
props.add("socketConnectionSetupTimeoutMs");
props.add("reconnectBackoffMaxMs");
- props.add("saslOauthbearerClockSkewSeconds");
- props.add("saslOauthbearerJwksEndpointUrl");
props.add("valueDeserializer");
props.add("metricReporters");
props.add("sslTruststoreType");
@@ -42,7 +40,6 @@ public class VertxKafkaEndpointUriFactory extends
org.apache.camel.support.compo
props.add("securityProviders");
props.add("retries");
props.add("enableAutoCommit");
- props.add("saslOauthbearerExpectedAudience");
props.add("isolationLevel");
props.add("maxPollRecords");
props.add("additionalProperties");
@@ -61,9 +58,7 @@ public class VertxKafkaEndpointUriFactory extends
org.apache.camel.support.compo
props.add("saslLoginCallbackHandlerClass");
props.add("headerFilterStrategy");
props.add("sslTruststorePassword");
- props.add("saslOauthbearerJwksEndpointRetryBackoffMs");
props.add("sessionTimeoutMs");
- props.add("saslOauthbearerJwksEndpointRetryBackoffMaxMs");
props.add("clientDnsLookup");
props.add("sslTruststoreLocation");
props.add("connectionsMaxIdleMs");
@@ -78,7 +73,6 @@ public class VertxKafkaEndpointUriFactory extends
org.apache.camel.support.compo
props.add("seekToPosition");
props.add("saslKerberosMinTimeBeforeRelogin");
props.add("sslKeystoreCertificateChain");
- props.add("saslOauthbearerJwksEndpointRefreshMs");
props.add("maxPollIntervalMs");
props.add("reconnectBackoffMs");
props.add("groupId");
@@ -87,12 +81,9 @@ public class VertxKafkaEndpointUriFactory extends
org.apache.camel.support.compo
props.add("metricsRecordingLevel");
props.add("compressionType");
props.add("saslKerberosServiceName");
- props.add("saslLoginConnectTimeoutMs");
props.add("bridgeErrorHandler");
props.add("saslLoginRefreshBufferSeconds");
props.add("saslMechanism");
- props.add("saslOauthbearerTokenEndpointUrl");
- props.add("saslLoginRetryBackoffMs");
props.add("deliveryTimeoutMs");
props.add("lazyStartProducer");
props.add("sslKeystorePassword");
@@ -118,16 +109,12 @@ public class VertxKafkaEndpointUriFactory extends
org.apache.camel.support.compo
props.add("autoCommitIntervalMs");
props.add("saslLoginRefreshWindowJitter");
props.add("bootstrapServers");
- props.add("saslOauthbearerSubClaimName");
props.add("sslEnabledProtocols");
props.add("sslKeystoreLocation");
props.add("defaultApiTimeoutMs");
props.add("metricsNumSamples");
- props.add("saslOauthbearerExpectedIssuer");
props.add("exchangePattern");
props.add("valueSerializer");
- props.add("saslLoginRetryBackoffMaxMs");
- props.add("saslOauthbearerScopeClaimName");
props.add("autoOffsetReset");
props.add("bufferMemory");
props.add("requestTimeoutMs");
@@ -135,7 +122,6 @@ public class VertxKafkaEndpointUriFactory extends
org.apache.camel.support.compo
props.add("clientRack");
props.add("transactionTimeoutMs");
props.add("fetchMaxBytes");
- props.add("saslLoginReadTimeoutMs");
props.add("batchSize");
props.add("sslSecureRandomImplementation");
props.add("checkCrcs");
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
index 0c85204..013d544 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/java/org/apache/camel/component/vertx/kafka/configuration/VertxKafkaConfiguration.java
@@ -28,7 +28,7 @@ public class VertxKafkaConfiguration
@UriParam(label = "common")
private String bootstrapServers;
// client.dns.lookup
- @UriParam(label = "common", defaultValue = "use_all_dns_ips", enums =
"use_all_dns_ips,resolve_canonical_bootstrap_servers_only")
+ @UriParam(label = "common", defaultValue = "use_all_dns_ips", enums =
"default,use_all_dns_ips,resolve_canonical_bootstrap_servers_only")
private String clientDnsLookup = "use_all_dns_ips";
// metadata.max.age.ms
@UriParam(label = "common", defaultValue = "5m", javaType =
"java.time.Duration")
@@ -183,48 +183,6 @@ public class VertxKafkaConfiguration
// sasl.login.class
@UriParam(label = "common,security")
private String saslLoginClass;
- // sasl.login.connect.timeout.ms
- @UriParam(label = "common,security", javaType = "java.time.Duration")
- private Integer saslLoginConnectTimeoutMs;
- // sasl.login.read.timeout.ms
- @UriParam(label = "common,security", javaType = "java.time.Duration")
- private Integer saslLoginReadTimeoutMs;
- // sasl.login.retry.backoff.max.ms
- @UriParam(label = "common,security", defaultValue = "10s", javaType =
"java.time.Duration")
- private long saslLoginRetryBackoffMaxMs = 10000;
- // sasl.login.retry.backoff.ms
- @UriParam(label = "common,security", defaultValue = "100ms", javaType =
"java.time.Duration")
- private long saslLoginRetryBackoffMs = 100;
- // sasl.oauthbearer.scope.claim.name
- @UriParam(label = "common,security", defaultValue = "scope")
- private String saslOauthbearerScopeClaimName = "scope";
- // sasl.oauthbearer.sub.claim.name
- @UriParam(label = "common,security", defaultValue = "sub")
- private String saslOauthbearerSubClaimName = "sub";
- // sasl.oauthbearer.token.endpoint.url
- @UriParam(label = "common,security")
- private String saslOauthbearerTokenEndpointUrl;
- // sasl.oauthbearer.jwks.endpoint.url
- @UriParam(label = "common,security")
- private String saslOauthbearerJwksEndpointUrl;
- // sasl.oauthbearer.jwks.endpoint.refresh.ms
- @UriParam(label = "common,security", defaultValue = "1h", javaType =
"java.time.Duration")
- private long saslOauthbearerJwksEndpointRefreshMs = 3600000;
- // sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms
- @UriParam(label = "common,security", defaultValue = "10s", javaType =
"java.time.Duration")
- private long saslOauthbearerJwksEndpointRetryBackoffMaxMs = 10000;
- // sasl.oauthbearer.jwks.endpoint.retry.backoff.ms
- @UriParam(label = "common,security", defaultValue = "100ms", javaType =
"java.time.Duration")
- private long saslOauthbearerJwksEndpointRetryBackoffMs = 100;
- // sasl.oauthbearer.clock.skew.seconds
- @UriParam(label = "common,security", defaultValue = "30")
- private int saslOauthbearerClockSkewSeconds = 30;
- // sasl.oauthbearer.expected.audience
- @UriParam(label = "common,security")
- private String saslOauthbearerExpectedAudience;
- // sasl.oauthbearer.expected.issuer
- @UriParam(label = "common,security")
- private String saslOauthbearerExpectedIssuer;
// Additional properties
@UriParam(label = "common", prefix = "additionalProperties.", multiValue =
true)
private Map<String, Object> additionalProperties = new HashMap<>();
@@ -241,14 +199,14 @@ public class VertxKafkaConfiguration
@UriParam(label = "consumer")
private String groupInstanceId;
// session.timeout.ms
- @UriParam(label = "consumer", defaultValue = "45s", javaType =
"java.time.Duration")
- private int sessionTimeoutMs = 45000;
+ @UriParam(label = "consumer", defaultValue = "10s", javaType =
"java.time.Duration")
+ private int sessionTimeoutMs = 10000;
// heartbeat.interval.ms
@UriParam(label = "consumer", defaultValue = "3s", javaType =
"java.time.Duration")
private int heartbeatIntervalMs = 3000;
// partition.assignment.strategy
- @UriParam(label = "consumer", defaultValue =
"org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor")
- private String partitionAssignmentStrategy =
"org.apache.kafka.clients.consumer.RangeAssignor,org.apache.kafka.clients.consumer.CooperativeStickyAssignor";
+ @UriParam(label = "consumer", defaultValue =
"org.apache.kafka.clients.consumer.RangeAssignor")
+ private String partitionAssignmentStrategy =
"org.apache.kafka.clients.consumer.RangeAssignor";
// enable.auto.commit
@UriParam(label = "consumer", defaultValue = "true")
private boolean enableAutoCommit = true;
@@ -307,8 +265,8 @@ public class VertxKafkaConfiguration
@UriParam(label = "producer", defaultValue = "2147483647")
private int retries = 2147483647;
// acks
- @UriParam(label = "producer", defaultValue = "all", enums = "all,-1,0,1")
- private String acks = "all";
+ @UriParam(label = "producer", defaultValue = "1", enums = "all,-1,0,1")
+ private String acks = "1";
// compression.type
@UriParam(label = "producer", defaultValue = "none")
private String compressionType = "none";
@@ -343,8 +301,8 @@ public class VertxKafkaConfiguration
@UriParam(label = "producer", defaultValue =
"org.apache.kafka.clients.producer.internals.DefaultPartitioner")
private String partitionerClass =
"org.apache.kafka.clients.producer.internals.DefaultPartitioner";
// enable.idempotence
- @UriParam(label = "producer", defaultValue = "true")
- private boolean enableIdempotence = true;
+ @UriParam(label = "producer", defaultValue = "false")
+ private boolean enableIdempotence = false;
// transaction.timeout.ms
@UriParam(label = "producer", defaultValue = "1m", javaType =
"java.time.Duration")
private int transactionTimeoutMs = 60000;
@@ -408,7 +366,10 @@ public class VertxKafkaConfiguration
* OS cache DNS name lookups, however). If set to
* <code>resolve_canonical_bootstrap_servers_only</code>, resolve each
* bootstrap address into a list of canonical names. After the bootstrap
- * phase, this behaves the same as <code>use_all_dns_ips</code>.
+ * phase, this behaves the same as <code>use_all_dns_ips</code>. If set to
+ * <code>default</code> (deprecated), attempt to connect to the first IP
+ * address returned by the lookup, even if the lookup returns multiple IP
+ * addresses.
*/
public void setClientDnsLookup(String clientDnsLookup) {
this.clientDnsLookup = clientDnsLookup;
@@ -1106,233 +1067,6 @@ public class VertxKafkaConfiguration
}
/**
- * The (optional) value in milliseconds for the external authentication
- * provider connection timeout. Currently applies only to OAUTHBEARER.
- */
- public void setSaslLoginConnectTimeoutMs(Integer
saslLoginConnectTimeoutMs) {
- this.saslLoginConnectTimeoutMs = saslLoginConnectTimeoutMs;
- }
-
- public Integer getSaslLoginConnectTimeoutMs() {
- return saslLoginConnectTimeoutMs;
- }
-
- /**
- * The (optional) value in milliseconds for the external authentication
- * provider read timeout. Currently applies only to OAUTHBEARER.
- */
- public void setSaslLoginReadTimeoutMs(Integer saslLoginReadTimeoutMs) {
- this.saslLoginReadTimeoutMs = saslLoginReadTimeoutMs;
- }
-
- public Integer getSaslLoginReadTimeoutMs() {
- return saslLoginReadTimeoutMs;
- }
-
- /**
- * The (optional) value in milliseconds for the maximum wait between login
- * attempts to the external authentication provider. Login uses an
- * exponential backoff algorithm with an initial wait based on the
- * sasl.login.retry.backoff.ms setting and will double in wait length
- * between attempts up to a maximum wait length specified by the
- * sasl.login.retry.backoff.max.ms setting. Currently applies only to
- * OAUTHBEARER.
- */
- public void setSaslLoginRetryBackoffMaxMs(long saslLoginRetryBackoffMaxMs)
{
- this.saslLoginRetryBackoffMaxMs = saslLoginRetryBackoffMaxMs;
- }
-
- public long getSaslLoginRetryBackoffMaxMs() {
- return saslLoginRetryBackoffMaxMs;
- }
-
- /**
- * The (optional) value in milliseconds for the initial wait between login
- * attempts to the external authentication provider. Login uses an
- * exponential backoff algorithm with an initial wait based on the
- * sasl.login.retry.backoff.ms setting and will double in wait length
- * between attempts up to a maximum wait length specified by the
- * sasl.login.retry.backoff.max.ms setting. Currently applies only to
- * OAUTHBEARER.
- */
- public void setSaslLoginRetryBackoffMs(long saslLoginRetryBackoffMs) {
- this.saslLoginRetryBackoffMs = saslLoginRetryBackoffMs;
- }
-
- public long getSaslLoginRetryBackoffMs() {
- return saslLoginRetryBackoffMs;
- }
-
- /**
- * The OAuth claim for the scope is often named "scope", but this
(optional)
- * setting can provide a different name to use for the scope included in
the
- * JWT payload's claims if the OAuth/OIDC provider uses a different name
for
- * that claim.
- */
- public void setSaslOauthbearerScopeClaimName(
- String saslOauthbearerScopeClaimName) {
- this.saslOauthbearerScopeClaimName = saslOauthbearerScopeClaimName;
- }
-
- public String getSaslOauthbearerScopeClaimName() {
- return saslOauthbearerScopeClaimName;
- }
-
- /**
- * The OAuth claim for the subject is often named "sub", but this
(optional)
- * setting can provide a different name to use for the subject included in
- * the JWT payload's claims if the OAuth/OIDC provider uses a different
name
- * for that claim.
- */
- public void setSaslOauthbearerSubClaimName(
- String saslOauthbearerSubClaimName) {
- this.saslOauthbearerSubClaimName = saslOauthbearerSubClaimName;
- }
-
- public String getSaslOauthbearerSubClaimName() {
- return saslOauthbearerSubClaimName;
- }
-
- /**
- * The URL for the OAuth/OIDC identity provider. If the URL is
- * HTTP(S)-based, it is the issuer's token endpoint URL to which requests
- * will be made to login based on the configuration in sasl.jaas.config. If
- * the URL is file-based, it specifies a file containing an access token
(in
- * JWT serialized form) issued by the OAuth/OIDC identity provider to use
- * for authorization.
- */
- public void setSaslOauthbearerTokenEndpointUrl(
- String saslOauthbearerTokenEndpointUrl) {
- this.saslOauthbearerTokenEndpointUrl = saslOauthbearerTokenEndpointUrl;
- }
-
- public String getSaslOauthbearerTokenEndpointUrl() {
- return saslOauthbearerTokenEndpointUrl;
- }
-
- /**
- * The OAuth/OIDC provider URL from which the provider's <a
- * href="https://datatracker.ietf.org/doc/html/rfc7517#section-5";>JWKS
(JSON
- * Web Key Set)</a> can be retrieved. The URL can be HTTP(S)-based or
- * file-based. If the URL is HTTP(S)-based, the JWKS data will be retrieved
- * from the OAuth/OIDC provider via the configured URL on broker startup.
- * All then-current keys will be cached on the broker for incoming
requests.
- * If an authentication request is received for a JWT that includes a "kid"
- * header claim value that isn't yet in the cache, the JWKS endpoint will
be
- * queried again on demand. However, the broker polls the URL every
- * sasl.oauthbearer.jwks.endpoint.refresh.ms milliseconds to refresh the
- * cache with any forthcoming keys before any JWT requests that include
them
- * are received. If the URL is file-based, the broker will load the JWKS
- * file from a configured location on startup. In the event that the JWT
- * includes a "kid" header value that isn't in the JWKS file, the broker
- * will reject the JWT and authentication will fail.
- */
- public void setSaslOauthbearerJwksEndpointUrl(
- String saslOauthbearerJwksEndpointUrl) {
- this.saslOauthbearerJwksEndpointUrl = saslOauthbearerJwksEndpointUrl;
- }
-
- public String getSaslOauthbearerJwksEndpointUrl() {
- return saslOauthbearerJwksEndpointUrl;
- }
-
- /**
- * The (optional) value in milliseconds for the broker to wait between
- * refreshing its JWKS (JSON Web Key Set) cache that contains the keys to
- * verify the signature of the JWT.
- */
- public void setSaslOauthbearerJwksEndpointRefreshMs(
- long saslOauthbearerJwksEndpointRefreshMs) {
- this.saslOauthbearerJwksEndpointRefreshMs =
saslOauthbearerJwksEndpointRefreshMs;
- }
-
- public long getSaslOauthbearerJwksEndpointRefreshMs() {
- return saslOauthbearerJwksEndpointRefreshMs;
- }
-
- /**
- * The (optional) value in milliseconds for the maximum wait between
- * attempts to retrieve the JWKS (JSON Web Key Set) from the external
- * authentication provider. JWKS retrieval uses an exponential backoff
- * algorithm with an initial wait based on the
- * sasl.oauthbearer.jwks.endpoint.retry.backoff.ms setting and will double
- * in wait length between attempts up to a maximum wait length specified by
- * the sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms setting.
- */
- public void setSaslOauthbearerJwksEndpointRetryBackoffMaxMs(
- long saslOauthbearerJwksEndpointRetryBackoffMaxMs) {
- this.saslOauthbearerJwksEndpointRetryBackoffMaxMs =
saslOauthbearerJwksEndpointRetryBackoffMaxMs;
- }
-
- public long getSaslOauthbearerJwksEndpointRetryBackoffMaxMs() {
- return saslOauthbearerJwksEndpointRetryBackoffMaxMs;
- }
-
- /**
- * The (optional) value in milliseconds for the initial wait between JWKS
- * (JSON Web Key Set) retrieval attempts from the external authentication
- * provider. JWKS retrieval uses an exponential backoff algorithm with an
- * initial wait based on the
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms
- * setting and will double in wait length between attempts up to a maximum
- * wait length specified by the
- * sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms setting.
- */
- public void setSaslOauthbearerJwksEndpointRetryBackoffMs(
- long saslOauthbearerJwksEndpointRetryBackoffMs) {
- this.saslOauthbearerJwksEndpointRetryBackoffMs =
saslOauthbearerJwksEndpointRetryBackoffMs;
- }
-
- public long getSaslOauthbearerJwksEndpointRetryBackoffMs() {
- return saslOauthbearerJwksEndpointRetryBackoffMs;
- }
-
- /**
- * The (optional) value in seconds to allow for differences between the
time
- * of the OAuth/OIDC identity provider and the broker.
- */
- public void setSaslOauthbearerClockSkewSeconds(
- int saslOauthbearerClockSkewSeconds) {
- this.saslOauthbearerClockSkewSeconds = saslOauthbearerClockSkewSeconds;
- }
-
- public int getSaslOauthbearerClockSkewSeconds() {
- return saslOauthbearerClockSkewSeconds;
- }
-
- /**
- * The (optional) comma-delimited setting for the broker to use to verify
- * that the JWT was issued for one of the expected audiences. The JWT will
- * be inspected for the standard OAuth "aud" claim and if this value is
set,
- * the broker will match the value from JWT's "aud" claim to see if there
- * is an exact match. If there is no match, the broker will reject the JWT
- * and authentication will fail.
- */
- public void setSaslOauthbearerExpectedAudience(
- String saslOauthbearerExpectedAudience) {
- this.saslOauthbearerExpectedAudience = saslOauthbearerExpectedAudience;
- }
-
- public String getSaslOauthbearerExpectedAudience() {
- return saslOauthbearerExpectedAudience;
- }
-
- /**
- * The (optional) setting for the broker to use to verify that the JWT was
- * created by the expected issuer. The JWT will be inspected for the
- * standard OAuth "iss" claim and if this value is set, the broker will
- * match it exactly against what is in the JWT's "iss" claim. If there is
no
- * match, the broker will reject the JWT and authentication will fail.
- */
- public void setSaslOauthbearerExpectedIssuer(
- String saslOauthbearerExpectedIssuer) {
- this.saslOauthbearerExpectedIssuer = saslOauthbearerExpectedIssuer;
- }
-
- public String getSaslOauthbearerExpectedIssuer() {
- return saslOauthbearerExpectedIssuer;
- }
-
- /**
* Sets additional properties for either kafka consumer or kafka producer
in
* case they can't be set directly on the camel configurations (e.g: new
* Kafka properties that are not reflected yet in Camel configurations),
the
@@ -1444,8 +1178,8 @@ public class VertxKafkaConfiguration
* partition ownership amongst consumer instances when group management is
* used. Available options
*
are:<ul><li><code>org.apache.kafka.clients.consumer.RangeAssignor</code>:
- * Assigns partitions on a per-topic
- *
basis.</li><li><code>org.apache.kafka.clients.consumer.RoundRobinAssignor</code>:
Assigns partitions to consumers in a round-robin
fashion.</li><li><code>org.apache.kafka.clients.consumer.StickyAssignor</code>:
Guarantees an assignment that is maximally balanced while preserving as many
existing partition assignments as
possible.</li><li><code>org.apache.kafka.clients.consumer.CooperativeStickyAssignor</code>:
Follows the same StickyAssignor logic, but allows for cooperative rebal [...]
+ * The default assignor, which works on a per-topic
+ *
basis.</li><li><code>org.apache.kafka.clients.consumer.RoundRobinAssignor</code>:
Assigns partitions to consumers in a round-robin
fashion.</li><li><code>org.apache.kafka.clients.consumer.StickyAssignor</code>:
Guarantees an assignment that is maximally balanced while preserving as many
existing partition assignments as
possible.</li><li><code>org.apache.kafka.clients.consumer.CooperativeStickyAssignor</code>:
Follows the same StickyAssignor logic, but allows for cooperative rebal [...]
*/
public void setPartitionAssignmentStrategy(
String partitionAssignmentStrategy) {
@@ -1820,12 +1554,7 @@ public class VertxKafkaConfiguration
* reduce throughput (a batch size of zero will disable batching entirely).
* A very large batch size may use memory a bit more wastefully as we will
* always allocate a buffer of the specified batch size in anticipation of
- * additional records.<p>Note: This setting gives the upper bound of the
- * batch size to be sent. If we have fewer than this many bytes accumulated
- * for this partition, we will 'linger' for the <code>linger.ms</code> time
- * waiting for more records to show up. This <code>linger.ms</code> setting
- * defaults to 0, which means we'll immediately send out a record even the
- * accumulated batch size is under this <code>batch.size</code> setting.
+ * additional records.
*/
public void setBatchSize(int batchSize) {
this.batchSize = batchSize;
@@ -1842,7 +1571,7 @@ public class VertxKafkaConfiguration
* in some circumstances the client may want to reduce the number of
* requests even under moderate load. This setting accomplishes this by
* adding a small amount of artificial delay—that is, rather than
- * immediately sending out a record, the producer will wait for up to the
+ * immediately sending out a record the producer will wait for up to the
* given delay to allow other records to be sent so that the sends can be
* batched together. This can be thought of as analogous to Nagle's
* algorithm in TCP. This setting gives the upper bound on the delay for
@@ -1936,10 +1665,9 @@ public class VertxKafkaConfiguration
/**
* The maximum number of unacknowledged requests the client will send on a
- * single connection before blocking. Note that if this config is set to be
- * greater than 1 and <code>enable.idempotence</code> is set to false,
there
- * is a risk of message re-ordering after a failed send due to retries
- * (i.e., if retries are enabled).
+ * single connection before blocking. Note that if this setting is set to
be
+ * greater than 1 and there are failed sends, there is a risk of message
+ * re-ordering due to retries (i.e., if retries are enabled).
*/
public void setMaxInFlightRequestsPerConnection(
int maxInFlightRequestsPerConnection) {
@@ -1975,9 +1703,8 @@ public class VertxKafkaConfiguration
}
/**
- * A class to use to determine which partition to be send to when produce
- * the records. Available options
- *
are:<ul><li><code>org.apache.kafka.clients.producer.internals.DefaultPartitioner</code>:
The default partitioner. This strategy will try sticking to a partition until
the batch is full, or <code>linger.ms</code> is up. It works with the
strategy:<ul><li>If no partition is specified but a key is present, choose a
partition based on a hash of the key</li><li>If no partition or key is present,
choose the sticky partition that changes when the batch is full, or
<code>linger.ms</code> [...]
+ * Partitioner class that implements the
+ * <code>org.apache.kafka.clients.producer.Partitioner</code> interface.
*/
public void setPartitionerClass(String partitionerClass) {
this.partitionerClass = partitionerClass;
@@ -1993,11 +1720,10 @@ public class VertxKafkaConfiguration
* to broker failures, etc., may write duplicates of the retried message in
* the stream. Note that enabling idempotence requires
* <code>max.in.flight.requests.per.connection</code> to be less than or
- * equal to 5 (with message ordering preserved for any allowable value),
- * <code>retries</code> to be greater than 0, and <code>acks</code> must be
- * 'all'. If these values are not explicitly set by the user, suitable
- * values will be chosen. If incompatible values are set, a
- * <code>ConfigException</code> will be thrown.
+ * equal to 5, <code>retries</code> to be greater than 0 and
+ * <code>acks</code> must be 'all'. If these values are not explicitly set
+ * by the user, suitable values will be chosen. If incompatible values are
+ * set, a <code>ConfigException</code> will be thrown.
*/
public void setEnableIdempotence(boolean enableIdempotence) {
this.enableIdempotence = enableIdempotence;
@@ -2101,20 +1827,6 @@ public class VertxKafkaConfiguration
addPropertyIfNotNull(props, "sasl.client.callback.handler.class",
saslClientCallbackHandlerClass);
addPropertyIfNotNull(props, "sasl.login.callback.handler.class",
saslLoginCallbackHandlerClass);
addPropertyIfNotNull(props, "sasl.login.class", saslLoginClass);
- addPropertyIfNotNull(props, "sasl.login.connect.timeout.ms",
saslLoginConnectTimeoutMs);
- addPropertyIfNotNull(props, "sasl.login.read.timeout.ms",
saslLoginReadTimeoutMs);
- addPropertyIfNotNull(props, "sasl.login.retry.backoff.max.ms",
saslLoginRetryBackoffMaxMs);
- addPropertyIfNotNull(props, "sasl.login.retry.backoff.ms",
saslLoginRetryBackoffMs);
- addPropertyIfNotNull(props, "sasl.oauthbearer.scope.claim.name",
saslOauthbearerScopeClaimName);
- addPropertyIfNotNull(props, "sasl.oauthbearer.sub.claim.name",
saslOauthbearerSubClaimName);
- addPropertyIfNotNull(props, "sasl.oauthbearer.token.endpoint.url",
saslOauthbearerTokenEndpointUrl);
- addPropertyIfNotNull(props, "sasl.oauthbearer.jwks.endpoint.url",
saslOauthbearerJwksEndpointUrl);
- addPropertyIfNotNull(props,
"sasl.oauthbearer.jwks.endpoint.refresh.ms",
saslOauthbearerJwksEndpointRefreshMs);
- addPropertyIfNotNull(props,
"sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms",
saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- addPropertyIfNotNull(props,
"sasl.oauthbearer.jwks.endpoint.retry.backoff.ms",
saslOauthbearerJwksEndpointRetryBackoffMs);
- addPropertyIfNotNull(props, "sasl.oauthbearer.clock.skew.seconds",
saslOauthbearerClockSkewSeconds);
- addPropertyIfNotNull(props, "sasl.oauthbearer.expected.audience",
saslOauthbearerExpectedAudience);
- addPropertyIfNotNull(props, "sasl.oauthbearer.expected.issuer",
saslOauthbearerExpectedIssuer);
addPropertyIfNotNull(props, "seek.to.offset", seekToOffset);
addPropertyIfNotNull(props, "seek.to.position", seekToPosition);
addPropertyIfNotNull(props, "group.id", groupId);
@@ -2200,20 +1912,6 @@ public class VertxKafkaConfiguration
addPropertyIfNotNull(props, "sasl.client.callback.handler.class",
saslClientCallbackHandlerClass);
addPropertyIfNotNull(props, "sasl.login.callback.handler.class",
saslLoginCallbackHandlerClass);
addPropertyIfNotNull(props, "sasl.login.class", saslLoginClass);
- addPropertyIfNotNull(props, "sasl.login.connect.timeout.ms",
saslLoginConnectTimeoutMs);
- addPropertyIfNotNull(props, "sasl.login.read.timeout.ms",
saslLoginReadTimeoutMs);
- addPropertyIfNotNull(props, "sasl.login.retry.backoff.max.ms",
saslLoginRetryBackoffMaxMs);
- addPropertyIfNotNull(props, "sasl.login.retry.backoff.ms",
saslLoginRetryBackoffMs);
- addPropertyIfNotNull(props, "sasl.oauthbearer.scope.claim.name",
saslOauthbearerScopeClaimName);
- addPropertyIfNotNull(props, "sasl.oauthbearer.sub.claim.name",
saslOauthbearerSubClaimName);
- addPropertyIfNotNull(props, "sasl.oauthbearer.token.endpoint.url",
saslOauthbearerTokenEndpointUrl);
- addPropertyIfNotNull(props, "sasl.oauthbearer.jwks.endpoint.url",
saslOauthbearerJwksEndpointUrl);
- addPropertyIfNotNull(props,
"sasl.oauthbearer.jwks.endpoint.refresh.ms",
saslOauthbearerJwksEndpointRefreshMs);
- addPropertyIfNotNull(props,
"sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms",
saslOauthbearerJwksEndpointRetryBackoffMaxMs);
- addPropertyIfNotNull(props,
"sasl.oauthbearer.jwks.endpoint.retry.backoff.ms",
saslOauthbearerJwksEndpointRetryBackoffMs);
- addPropertyIfNotNull(props, "sasl.oauthbearer.clock.skew.seconds",
saslOauthbearerClockSkewSeconds);
- addPropertyIfNotNull(props, "sasl.oauthbearer.expected.audience",
saslOauthbearerExpectedAudience);
- addPropertyIfNotNull(props, "sasl.oauthbearer.expected.issuer",
saslOauthbearerExpectedIssuer);
addPropertyIfNotNull(props, "buffer.memory", bufferMemory);
addPropertyIfNotNull(props, "retries", retries);
addPropertyIfNotNull(props, "acks", acks);
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
index f8d1c56..aca8dd2 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/generated/resources/org/apache/camel/component/vertx/kafka/vertx-kafka.json
@@ -24,7 +24,7 @@
"componentProperties": {
"additionalProperties": { "kind": "property", "displayName": "Additional
Properties", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
"prefix": "additionalProperties.", "multiValue": true, "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descrip [...]
"bootstrapServers": { "kind": "property", "displayName": "Bootstrap
Servers", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A list of host\/port
pairs to use for establishing the initial connection to the Kafka c [...]
- "clientDnsLookup": { "kind": "property", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "use_all_dns_ips",
"resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configurati [...]
+ "clientDnsLookup": { "kind": "property", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "default",
"use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": " [...]
"clientId": { "kind": "property", "displayName": "Client Id", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "An id string to pass to
the server when making requests. The purpose of this is to be able to track the
[...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configurations" },
"connectionsMaxIdleMs": { "kind": "property", "displayName": "Connections
Max Idle Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "9m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Close idle connections
after the number of milliseconds specified [...]
@@ -65,26 +65,26 @@
"maxPartitionFetchBytes": { "kind": "property", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "property", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer g [...]
"maxPollRecords": { "kind": "property", "displayName": "Max Poll Records",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
- "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "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,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfi [...]
+ "partitionAssignmentStrategy": { "kind": "property", "displayName":
"Partition Assignment Strategy", "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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descripti [...]
"seekToOffset": { "kind": "property", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take pr [...]
"seekToPosition": { "kind": "property", "displayName": "Seek To Position",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "beginning", "end" ], "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end on [...]
- "sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "45s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group man [...]
+ "sessionTimeoutMs": { "kind": "property", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group man [...]
"valueDeserializer": { "kind": "property", "displayName": "Value
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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deseri [...]
"kafkaManualCommitFactory": { "kind": "property", "displayName": "Kafka
Manual Commit Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommitFactory",
"deprecated": false, "autowired": true, "secret": false, "description":
"Factory to use for creating
org.apache.camel.component.vertx.kafka.offset.VertxKafkaManualCommit instances.
This allows to plugin [...]
- "acks": { "kind": "property", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "all",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer requires [...]
- "batchSize": { "kind": "property", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multip [...]
+ "acks": { "kind": "property", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer requires t [...]
+ "batchSize": { "kind": "property", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multip [...]
"bufferMemory": { "kind": "property", "displayName": "Buffer Memory",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 33554432, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The total bytes of
memory the producer can use to buffer records waiting to b [...]
"compressionType": { "kind": "property", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "none", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The compression type for
all data generated by the producer. T [...]
"deliveryTimeoutMs": { "kind": "property", "displayName": "Delivery
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "2m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "An upper bound on the
time to report success or failure after a call t [...]
- "enableIdempotence": { "kind": "property", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "When set to 'true', the
producer will ensure that exactly one copy o [...]
+ "enableIdempotence": { "kind": "property", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "When set to 'true', the
producer will ensure that exactly one copy [...]
"keySerializer": { "kind": "property", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Serializer class [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": 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 star [...]
- "lingerMs": { "kind": "property", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer groups
together any records that arrive in between request transmissions i [...]
+ "lingerMs": { "kind": "property", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer groups
together any records that arrive in between request transmissions i [...]
"maxBlockMs": { "kind": "property", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls how long the KafkaProducer's send(), partitionsFor(), in [...]
- "maxInFlightRequestsPerConnection": { "kind": "property", "displayName":
"Max In Flight Requests Per Connection", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
unacknowledged requ [...]
+ "maxInFlightRequestsPerConnection": { "kind": "property", "displayName":
"Max In Flight Requests Per Connection", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
unacknowledged requ [...]
"maxRequestSize": { "kind": "property", "displayName": "Max Request Size",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum size of a
request in bytes. This setting will limit the number [...]
"metadataMaxIdleMs": { "kind": "property", "displayName": "Metadata Max
Idle Ms", "group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Controls how long the
producer will cache metadata for a topic that' [...]
- "partitionerClass": { "kind": "property", "displayName": "Partitioner
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A [...]
+ "partitionerClass": { "kind": "property", "displayName": "Partitioner
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Pa [...]
"retries": { "kind": "property", "displayName": "Retries", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Setting a value greater
than zero will cause the client to resend any record whose send [...]
"transactionalId": { "kind": "property", "displayName": "Transactional
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The TransactionalId to
use for transactional delivery. This enables reliability semant [...]
"transactionTimeoutMs": { "kind": "property", "displayName": "Transaction
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time in ms that the transaction coordinato [...]
@@ -102,25 +102,11 @@
"saslKerberosTicketRenewWindowFactor": { "kind": "property",
"displayName": "Sasl Kerberos Ticket Renew Window Factor", "group": "security",
"label": "common,security", "required": false, "type": "number", "javaType":
"double", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0.8, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread will sleep
[...]
"saslLoginCallbackHandlerClass": { "kind": "property", "displayName":
"Sasl Login Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL login callbac [...]
"saslLoginClass": { "kind": "property", "displayName": "Sasl Login Class",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a class that implements the Login interface. For bro [...]
- "saslLoginConnectTimeoutMs": { "kind": "property", "displayName": "Sasl
Login Connect Timeout Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the external [...]
- "saslLoginReadTimeoutMs": { "kind": "property", "displayName": "Sasl Login
Read Timeout Ms", "group": "security", "label": "common,security", "required":
false, "type": "duration", "javaType": "java.lang.Integer", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the external authe [...]
"saslLoginRefreshBufferSeconds": { "kind": "property", "displayName":
"Sasl Login Refresh Buffer Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"300", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of buffer
time before cr [...]
"saslLoginRefreshMinPeriodSeconds": { "kind": "property", "displayName":
"Sasl Login Refresh Min Period Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": "60",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The desired minimum time
for [...]
"saslLoginRefreshWindowFactor": { "kind": "property", "displayName": "Sasl
Login Refresh Window Factor", "group": "security", "label": "common,security",
"required": false, "type": "number", "javaType": "double", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 0.8, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login refresh thread
will sleep until t [...]
"saslLoginRefreshWindowJitter": { "kind": "property", "displayName": "Sasl
Login Refresh Window Jitter", "group": "security", "label": "common,security",
"required": false, "type": "number", "javaType": "double", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 0.05,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
random jitter re [...]
- "saslLoginRetryBackoffMaxMs": { "kind": "property", "displayName": "Sasl
Login Retry Backoff Max Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for [...]
- "saslLoginRetryBackoffMs": { "kind": "property", "displayName": "Sasl
Login Retry Backoff Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "100ms",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the [...]
"saslMechanism": { "kind": "property", "displayName": "Sasl Mechanism",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "GSSAPI", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "SASL mechanism used for
client connections. This may be a [...]
- "saslOauthbearerClockSkewSeconds": { "kind": "property", "displayName":
"Sasl Oauthbearer Clock Skew Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 30,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
seconds to a [...]
- "saslOauthbearerExpectedAudience": { "kind": "property", "displayName":
"Sasl Oauthbearer Expected Audience", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional)
comma-delimited setting for th [...]
- "saslOauthbearerExpectedIssuer": { "kind": "property", "displayName":
"Sasl Oauthbearer Expected Issuer", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) setting
for the broker to use to v [...]
- "saslOauthbearerJwksEndpointRefreshMs": { "kind": "property",
"displayName": "Sasl Oauthbearer Jwks Endpoint Refresh Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1h", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value
[...]
- "saslOauthbearerJwksEndpointRetryBackoffMaxMs": { "kind": "property",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Max Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Th [...]
- "saslOauthbearerJwksEndpointRetryBackoffMs": { "kind": "property",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (op [...]
- "saslOauthbearerJwksEndpointUrl": { "kind": "property", "displayName":
"Sasl Oauthbearer Jwks Endpoint Url", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth\/OIDC provider
URL from which the pr [...]
- "saslOauthbearerScopeClaimName": { "kind": "property", "displayName":
"Sasl Oauthbearer Scope Claim Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "scope", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for the
[...]
- "saslOauthbearerSubClaimName": { "kind": "property", "displayName": "Sasl
Oauthbearer Sub Claim Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"sub", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for the
subje [...]
- "saslOauthbearerTokenEndpointUrl": { "kind": "property", "displayName":
"Sasl Oauthbearer Token Endpoint Url", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The URL for the
OAuth\/OIDC identity provide [...]
"securityProtocol": { "kind": "property", "displayName": "Security
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PLAINTEXT",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Protocol used to
communicate with brokers. Valid [...]
"securityProviders": { "kind": "property", "displayName": "Security
Providers", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A list of configurable
creator classes each returning a provider implementi [...]
"sslCipherSuites": { "kind": "property", "displayName": "Ssl Cipher
Suites", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A list of cipher suites.
This is a named combination of authentication, encryp [...]
@@ -147,7 +133,7 @@
"topic": { "kind": "path", "displayName": "Topic", "group": "common",
"label": "common", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Name of the topic to
use. On the consumer you can use comma to separate multiple topics. A pr [...]
"additionalProperties": { "kind": "parameter", "displayName": "Additional
Properties", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
"prefix": "additionalProperties.", "multiValue": true, "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descri [...]
"bootstrapServers": { "kind": "parameter", "displayName": "Bootstrap
Servers", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A list of host\/port
pairs to use for establishing the initial connection to the Kafka [...]
- "clientDnsLookup": { "kind": "parameter", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "use_all_dns_ips",
"resolve_canonical_bootstrap_servers_only" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configurat [...]
+ "clientDnsLookup": { "kind": "parameter", "displayName": "Client Dns
Lookup", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "default",
"use_all_dns_ips", "resolve_canonical_bootstrap_servers_only" ], "deprecated":
false, "autowired": false, "secret": false, "defaultValue": "use_all_dns_ips",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": [...]
"clientId": { "kind": "parameter", "displayName": "Client Id", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "An id string to pass to
the server when making requests. The purpose of this is to be able to track the
[...]
"connectionsMaxIdleMs": { "kind": "parameter", "displayName": "Connections
Max Idle Ms", "group": "common", "label": "common", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "9m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Close idle connections
after the number of milliseconds specified [...]
"headerFilterStrategy": { "kind": "parameter", "displayName": "Header
Filter Strategy", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "org.apache.camel.spi.HeaderFilterStrategy",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "To use a custom
HeaderFilterStrategy to filter header [...]
@@ -187,27 +173,27 @@
"maxPartitionFetchBytes": { "kind": "parameter", "displayName": "Max
Partition Fetch Bytes", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
data per-partition the server will [...]
"maxPollIntervalMs": { "kind": "parameter", "displayName": "Max Poll
Interval Ms", "group": "consumer", "label": "consumer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum delay
between invocations of poll() when using consumer [...]
"maxPollRecords": { "kind": "parameter", "displayName": "Max Poll
Records", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records returned in a single call to poll(). Note, that [...]
- "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "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,org.apache.kafka.clients.consumer.CooperativeStickyAssignor",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConf [...]
+ "partitionAssignmentStrategy": { "kind": "parameter", "displayName":
"Partition Assignment Strategy", "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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "descript [...]
"seekToOffset": { "kind": "parameter", "displayName": "Seek To Offset",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "java.lang.Long", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from a particular offset on startup. This config will take p [...]
"seekToPosition": { "kind": "parameter", "displayName": "Seek To
Position", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "beginning", "end" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Set if KafkaConsumer
will read from beginning or end o [...]
- "sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "45s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group ma [...]
+ "sessionTimeoutMs": { "kind": "parameter", "displayName": "Session Timeout
Ms", "group": "consumer", "label": "consumer", "required": false, "type":
"duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The timeout used to
detect client failures when using Kafka's group ma [...]
"valueDeserializer": { "kind": "parameter", "displayName": "Value
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.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Deser [...]
"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, "autowired": 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
con [...]
"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, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
- "acks": { "kind": "parameter", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "all",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer require [...]
- "batchSize": { "kind": "parameter", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multi [...]
+ "acks": { "kind": "parameter", "displayName": "Acks", "group": "producer",
"label": "producer", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "all", "-1", "0", "1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The number of
acknowledgments the producer requires [...]
+ "batchSize": { "kind": "parameter", "displayName": "Batch Size", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 16384, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer will
attempt to batch records together into fewer requests whenever multi [...]
"bufferMemory": { "kind": "parameter", "displayName": "Buffer Memory",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 33554432, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The total bytes of
memory the producer can use to buffer records waiting to [...]
"compressionType": { "kind": "parameter", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "none", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The compression type for
all data generated by the producer. [...]
"deliveryTimeoutMs": { "kind": "parameter", "displayName": "Delivery
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "2m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "An upper bound on the
time to report success or failure after a call [...]
- "enableIdempotence": { "kind": "parameter", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "When set to 'true', the
producer will ensure that exactly one copy [...]
+ "enableIdempotence": { "kind": "parameter", "displayName": "Enable
Idempotence", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "When set to 'true', the
producer will ensure that exactly one copy [...]
"keySerializer": { "kind": "parameter", "displayName": "Key Serializer",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringSerializer", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Serializer clas [...]
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": 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 sta [...]
- "lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer groups
together any records that arrive in between request transmissions [...]
+ "lingerMs": { "kind": "parameter", "displayName": "Linger Ms", "group":
"producer", "label": "producer", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The producer groups
together any records that arrive in between request transmissions [...]
"maxBlockMs": { "kind": "parameter", "displayName": "Max Block Ms",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The configuration
controls how long the KafkaProducer's send(), partitionsFor(), i [...]
- "maxInFlightRequestsPerConnection": { "kind": "parameter", "displayName":
"Max In Flight Requests Per Connection", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
unacknowledged req [...]
+ "maxInFlightRequestsPerConnection": { "kind": "parameter", "displayName":
"Max In Flight Requests Per Connection", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum number of
unacknowledged req [...]
"maxRequestSize": { "kind": "parameter", "displayName": "Max Request
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1048576, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum size of a
request in bytes. This setting will limit the numbe [...]
"metadataMaxIdleMs": { "kind": "parameter", "displayName": "Metadata Max
Idle Ms", "group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Controls how long the
producer will cache metadata for a topic that [...]
- "partitionerClass": { "kind": "parameter", "displayName": "Partitioner
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A [...]
+ "partitionerClass": { "kind": "parameter", "displayName": "Partitioner
Class", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue":
"org.apache.kafka.clients.producer.internals.DefaultPartitioner",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "P [...]
"retries": { "kind": "parameter", "displayName": "Retries", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 2147483647, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Setting a value greater
than zero will cause the client to resend any record whose sen [...]
"transactionalId": { "kind": "parameter", "displayName": "Transactional
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The TransactionalId to
use for transactional delivery. This enables reliability seman [...]
"transactionTimeoutMs": { "kind": "parameter", "displayName": "Transaction
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "duration", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1m", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
time in ms that the transaction coordinat [...]
@@ -221,25 +207,11 @@
"saslKerberosTicketRenewWindowFactor": { "kind": "parameter",
"displayName": "Sasl Kerberos Ticket Renew Window Factor", "group": "security",
"label": "common,security", "required": false, "type": "number", "javaType":
"double", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0.8, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login thread will sleep
[...]
"saslLoginCallbackHandlerClass": { "kind": "parameter", "displayName":
"Sasl Login Callback Handler Class", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a SASL login callba [...]
"saslLoginClass": { "kind": "parameter", "displayName": "Sasl Login
Class", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The fully qualified name
of a class that implements the Login interface. For br [...]
- "saslLoginConnectTimeoutMs": { "kind": "parameter", "displayName": "Sasl
Login Connect Timeout Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the externa [...]
- "saslLoginReadTimeoutMs": { "kind": "parameter", "displayName": "Sasl
Login Read Timeout Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the external auth [...]
"saslLoginRefreshBufferSeconds": { "kind": "parameter", "displayName":
"Sasl Login Refresh Buffer Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"300", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The amount of buffer
time before c [...]
"saslLoginRefreshMinPeriodSeconds": { "kind": "parameter", "displayName":
"Sasl Login Refresh Min Period Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "short",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": "60",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The desired minimum time
for [...]
"saslLoginRefreshWindowFactor": { "kind": "parameter", "displayName":
"Sasl Login Refresh Window Factor", "group": "security", "label":
"common,security", "required": false, "type": "number", "javaType": "double",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.8,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Login refresh thread
will sleep until [...]
"saslLoginRefreshWindowJitter": { "kind": "parameter", "displayName":
"Sasl Login Refresh Window Jitter", "group": "security", "label":
"common,security", "required": false, "type": "number", "javaType": "double",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 0.05,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The maximum amount of
random jitter r [...]
- "saslLoginRetryBackoffMaxMs": { "kind": "parameter", "displayName": "Sasl
Login Retry Backoff Max Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds fo [...]
- "saslLoginRetryBackoffMs": { "kind": "parameter", "displayName": "Sasl
Login Retry Backoff Ms", "group": "security", "label": "common,security",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "100ms",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
milliseconds for the [...]
"saslMechanism": { "kind": "parameter", "displayName": "Sasl Mechanism",
"group": "security", "label": "common,security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "GSSAPI", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "SASL mechanism used for
client connections. This may be [...]
- "saslOauthbearerClockSkewSeconds": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Clock Skew Seconds", "group": "security", "label":
"common,security", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 30,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value in
seconds to [...]
- "saslOauthbearerExpectedAudience": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Expected Audience", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional)
comma-delimited setting for t [...]
- "saslOauthbearerExpectedIssuer": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Expected Issuer", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) setting
for the broker to use to [...]
- "saslOauthbearerJwksEndpointRefreshMs": { "kind": "parameter",
"displayName": "Sasl Oauthbearer Jwks Endpoint Refresh Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "1h", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (optional) value
[...]
- "saslOauthbearerJwksEndpointRetryBackoffMaxMs": { "kind": "parameter",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Max Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10s", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "T [...]
- "saslOauthbearerJwksEndpointRetryBackoffMs": { "kind": "parameter",
"displayName": "Sasl Oauthbearer Jwks Endpoint Retry Backoff Ms", "group":
"security", "label": "common,security", "required": false, "type": "duration",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "100ms", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The (o [...]
- "saslOauthbearerJwksEndpointUrl": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Jwks Endpoint Url", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth\/OIDC provider
URL from which the p [...]
- "saslOauthbearerScopeClaimName": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Scope Claim Name", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "scope", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for th
[...]
- "saslOauthbearerSubClaimName": { "kind": "parameter", "displayName": "Sasl
Oauthbearer Sub Claim Name", "group": "security", "label": "common,security",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"sub", "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The OAuth claim for the
subj [...]
- "saslOauthbearerTokenEndpointUrl": { "kind": "parameter", "displayName":
"Sasl Oauthbearer Token Endpoint Url", "group": "security", "label":
"common,security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "The URL for the
OAuth\/OIDC identity provid [...]
"securityProtocol": { "kind": "parameter", "displayName": "Security
Protocol", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PLAINTEXT",
"configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "Protocol used to
communicate with brokers. Vali [...]
"securityProviders": { "kind": "parameter", "displayName": "Security
Providers", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A list of configurable
creator classes each returning a provider implement [...]
"sslCipherSuites": { "kind": "parameter", "displayName": "Ssl Cipher
Suites", "group": "security", "label": "common,security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration",
"configurationField": "configuration", "description": "A list of cipher suites.
This is a named combination of authentication, encry [...]
diff --git a/components/camel-vertx/camel-vertx-kafka/pom.xml
b/components/camel-vertx/camel-vertx-kafka/pom.xml
index bc7c699..c4bb689 100644
--- a/components/camel-vertx/camel-vertx-kafka/pom.xml
+++ b/components/camel-vertx/camel-vertx-kafka/pom.xml
@@ -50,10 +50,22 @@
<artifactId>camel-vertx-common</artifactId>
</dependency>
+ <!-- vertx-kafka only support kafka 2.x -->
+ <dependency>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>kafka-clients</artifactId>
+ <version>${kafka-vertx-version}</version>
+ </dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-kafka-client</artifactId>
<version>${vertx-version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
</dependency>
</dependencies>
diff --git a/parent/pom.xml b/parent/pom.xml
index b94cdbb..fdd417f 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -352,6 +352,7 @@
<jython-standalone-version>2.7.2</jython-standalone-version>
<jzlib-version>1.1.3</jzlib-version>
<kafka-version>3.1.0</kafka-version>
+ <kafka-vertx-version>2.8.1</kafka-vertx-version>
<kotlin-version>1.6.10</kotlin-version>
<kubernetes-client-version>5.12.0</kubernetes-client-version>
<kubernetes-model-version>5.12.0</kubernetes-model-version>
