This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/master by this push: new ace95d4 [create-pull-request] automated change ace95d4 is described below commit ace95d46427b7dc5a9872ee76e8f0f465e45ecb4 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Mon Jan 25 01:13:04 2021 +0000 [create-pull-request] automated change --- .../camel/springboot/catalog/components/kafka.json | 1 + .../springboot/catalog/components/vertx-kafka.json | 2 ++ .../src/main/docs/kafka-starter.adoc | 3 ++- .../springboot/KafkaComponentConfiguration.java | 20 ++++++++++++++++++++ .../kafka/springboot/KafkaComponentConverter.java | 2 ++ .../src/main/docs/vertx-kafka-starter.adoc | 3 ++- .../springboot/VertxKafkaComponentConfiguration.java | 19 +++++++++++++++++++ .../springboot/VertxKafkaComponentConverter.java | 2 ++ docs/modules/ROOT/pages/kafka-starter.adoc | 3 ++- docs/modules/ROOT/pages/vertx-kafka-starter.adoc | 3 ++- 10 files changed, 54 insertions(+), 4 deletions(-) diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json index 311e2d7..ab26b6f 100644 --- a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json +++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json @@ -92,6 +92,7 @@ "workerPoolCoreSize": { "kind": "property", "displayName": "Worker Pool Core Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Number of core threads for the worker pool for continue routing Exchange after [...] "workerPoolMaxSize": { "kind": "property", "displayName": "Worker Pool Max Size", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "20", "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Maximum number of threads for the worker pool for continue routing Exchange after [...] "autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...] + "kafkaClientFactory": { "kind": "property", "displayName": "Kafka Client Factory", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.kafka.KafkaClientFactory", "deprecated": false, "autowired": false, "secret": false, "description": "Factory to use for creating org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances. This allows to configure a custom factory to c [...] "synchronous": { "kind": "property", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Sets whether synchronous processing should be strictly used" }, "schemaRegistryURL": { "kind": "property", "displayName": "Schema Registry URL", "group": "confluent", "label": "confluent", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "URL of the Confluent Platform schema registry servers to use. The format is host1:port1,host2:port2. Thi [...] "interceptorClasses": { "kind": "property", "displayName": "Interceptor Classes", "group": "monitoring", "label": "common,monitoring", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration", "configurationField": "configuration", "description": "Sets interceptors for producer or consumers. Producer interceptors have to be classes implemen [...] diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json index 734e9be..555123b 100644 --- a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json +++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-kafka.json @@ -89,6 +89,7 @@ "valueSerializer": { "kind": "property", "displayName": "Value 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 c [...] "autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...] "vertx": { "kind": "property", "displayName": "Vertx", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "io.vertx.core.Vertx", "deprecated": false, "autowired": true, "secret": false, "description": "To use an existing vertx instead of creating a new instance" }, + "vertxKafkaClientFactory": { "kind": "property", "displayName": "Vertx Kafka Client Factory", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Factory to use for cre [...] "vertxOptions": { "kind": "property", "displayName": "Vertx Options", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "io.vertx.core.VertxOptions", "deprecated": false, "autowired": false, "secret": false, "description": "To provide a custom set of vertx options for configuring vertx" }, "saslClientCallbackHandlerClass": { "kind": "property", "displayName": "Sasl Client 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 client call [...] "saslJaasConfig": { "kind": "property", "displayName": "Sasl Jaas Config", "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": "JAAS login context parameters for SASL connections in the format used by JAAS co [...] @@ -194,6 +195,7 @@ "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 [...] "valueSerializer": { "kind": "parameter", "displayName": "Value 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 [...] + "vertxKafkaClientFactory": { "kind": "parameter", "displayName": "Vertx Kafka Client Factory", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Factory to use for cr [...] "saslClientCallbackHandlerClass": { "kind": "parameter", "displayName": "Sasl Client 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 client cal [...] "saslJaasConfig": { "kind": "parameter", "displayName": "Sasl Jaas Config", "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": "JAAS login context parameters for SASL connections in the format used by JAAS c [...] "saslKerberosKinitCmd": { "kind": "parameter", "displayName": "Sasl Kerberos Kinit Cmd", "group": "security", "label": "common,security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "\/usr\/bin\/kinit", "configurationClass": "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration", "configurationField": "configuration", "description": "Kerberos kinit command path." }, diff --git a/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc b/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc index 9a031fc..447b47f 100644 --- a/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc +++ b/components-starter/camel-kafka-starter/src/main/docs/kafka-starter.adoc @@ -17,7 +17,7 @@ When using kafka with Spring Boot make sure to use the following Maven dependenc ---- -The component supports 99 options, which are listed below. +The component supports 100 options, which are listed below. @@ -54,6 +54,7 @@ The component supports 99 options, which are listed below. | *camel.component.kafka.header-serializer* | To use a custom KafkaHeaderSerializer to serialize kafka headers values. The option is a org.apache.camel.component.kafka.serde.KafkaHeaderSerializer type. | | KafkaHeaderSerializer | *camel.component.kafka.heartbeat-interval-ms* | The expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group. The value must be set lower than session.timeout.ms, but typically should be set no higher than 1/3 of that value. It can be adjusted even lower to control the expected time for normal [...] | *camel.component.kafka.interceptor-classes* | Sets interceptors for producer or consumers. Producer interceptors have to be classes implementing org.apache.kafka.clients.producer.ProducerInterceptor Consumer interceptors have to be classes implementing org.apache.kafka.clients.consumer.ConsumerInterceptor Note that if you use Producer interceptor on a consumer it will throw a class cast exception in runtime | | String +| *camel.component.kafka.kafka-client-factory* | Factory to use for creating org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances. This allows to configure a custom factory to create org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances with logic that extends the vanilla Kafka clients. The option is a org.apache.camel.component.kafka.KafkaClientFactory type. | | KafkaClientFactory | *camel.component.kafka.kafka-manual-commit-factory* | Factory to use for creating KafkaManualCommit instances. This allows to plugin a custom factory to create custom KafkaManualCommit instances in case special logic is needed when doing manual commits that deviates from the default implementation that comes out of the box. The option is a org.apache.camel.component.kafka.KafkaManualCommitFactory type. | | KafkaManualCommitFactory | *camel.component.kafka.kerberos-before-relogin-min-time* | Login thread sleep time between refresh attempts. | 60000 | Integer | *camel.component.kafka.kerberos-init-cmd* | Kerberos kinit command path. Default is /usr/bin/kinit | /usr/bin/kinit | String diff --git a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java index 734c49a..c65e52f 100644 --- a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java +++ b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java @@ -19,6 +19,7 @@ package org.apache.camel.component.kafka.springboot; import java.util.Map; import java.util.concurrent.ExecutorService; import javax.annotation.Generated; +import org.apache.camel.component.kafka.KafkaClientFactory; import org.apache.camel.component.kafka.KafkaConfiguration; import org.apache.camel.component.kafka.KafkaManualCommitFactory; import org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer; @@ -540,6 +541,17 @@ public class KafkaComponentConfiguration */ private Boolean autowiredEnabled = true; /** + * Factory to use for creating + * org.apache.kafka.clients.consumer.KafkaConsumer and + * org.apache.kafka.clients.producer.KafkaProducer instances. This allows to + * configure a custom factory to create + * org.apache.kafka.clients.consumer.KafkaConsumer and + * org.apache.kafka.clients.producer.KafkaProducer instances with logic that + * extends the vanilla Kafka clients. The option is a + * org.apache.camel.component.kafka.KafkaClientFactory type. + */ + private KafkaClientFactory kafkaClientFactory; + /** * Sets whether synchronous processing should be strictly used */ private Boolean synchronous = false; @@ -1260,6 +1272,14 @@ public class KafkaComponentConfiguration this.autowiredEnabled = autowiredEnabled; } + public KafkaClientFactory getKafkaClientFactory() { + return kafkaClientFactory; + } + + public void setKafkaClientFactory(KafkaClientFactory kafkaClientFactory) { + this.kafkaClientFactory = kafkaClientFactory; + } + public Boolean getSynchronous() { return synchronous; } diff --git a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java index 289f358..1018ae6 100644 --- a/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java +++ b/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConverter.java @@ -46,6 +46,7 @@ public class KafkaComponentConverter answer.add(new ConvertiblePair(String.class, org.apache.camel.component.kafka.KafkaManualCommitFactory.class)); answer.add(new ConvertiblePair(String.class, org.apache.camel.component.kafka.serde.KafkaHeaderSerializer.class)); answer.add(new ConvertiblePair(String.class, java.util.concurrent.ExecutorService.class)); + answer.add(new ConvertiblePair(String.class, org.apache.camel.component.kafka.KafkaClientFactory.class)); answer.add(new ConvertiblePair(String.class, org.apache.camel.support.jsse.SSLContextParameters.class)); return answer; } @@ -70,6 +71,7 @@ public class KafkaComponentConverter case "org.apache.camel.component.kafka.KafkaManualCommitFactory": return camelContext.getRegistry().lookupByNameAndType(ref, org.apache.camel.component.kafka.KafkaManualCommitFactory.class); case "org.apache.camel.component.kafka.serde.KafkaHeaderSerializer": return camelContext.getRegistry().lookupByNameAndType(ref, org.apache.camel.component.kafka.serde.KafkaHeaderSerializer.class); case "java.util.concurrent.ExecutorService": return camelContext.getRegistry().lookupByNameAndType(ref, java.util.concurrent.ExecutorService.class); + case "org.apache.camel.component.kafka.KafkaClientFactory": return camelContext.getRegistry().lookupByNameAndType(ref, org.apache.camel.component.kafka.KafkaClientFactory.class); case "org.apache.camel.support.jsse.SSLContextParameters": return camelContext.getRegistry().lookupByNameAndType(ref, org.apache.camel.support.jsse.SSLContextParameters.class); } return null; diff --git a/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc index 8de0c38..ff57de6 100644 --- a/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc +++ b/components-starter/camel-vertx-kafka-starter/src/main/docs/vertx-kafka-starter.adoc @@ -17,7 +17,7 @@ When using vertx-kafka with Spring Boot make sure to use the following Maven dep ---- -The component supports 104 options, which are listed below. +The component supports 105 options, which are listed below. @@ -127,6 +127,7 @@ The component supports 104 options, which are listed below. | *camel.component.vertx-kafka.value-deserializer* | Deserializer class for value that implements the org.apache.kafka.common.serialization.Deserializer interface. | org.apache.kafka.common.serialization.StringDeserializer | String | *camel.component.vertx-kafka.value-serializer* | Serializer class for value that implements the org.apache.kafka.common.serialization.Serializer interface. | org.apache.kafka.common.serialization.StringSerializer | String | *camel.component.vertx-kafka.vertx* | To use an existing vertx instead of creating a new instance. The option is a io.vertx.core.Vertx type. | | Vertx +| *camel.component.vertx-kafka.vertx-kafka-client-factory* | Factory to use for creating io.vertx.kafka.client.consumer.KafkaConsumer and io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to configure a custom factory to create custom KafkaConsumer and KafkaProducer instances with logic that extends the vanilla VertX Kafka clients. The option is a org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory type. | | VertxKafkaClientFactory | *camel.component.vertx-kafka.vertx-options* | To provide a custom set of vertx options for configuring vertx. The option is a io.vertx.core.VertxOptions type. | | VertxOptions |=== // spring-boot-auto-configure options: END diff --git a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java index d2c1215..eba4156 100644 --- a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java +++ b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConfiguration.java @@ -20,6 +20,7 @@ import java.util.Map; import javax.annotation.Generated; import io.vertx.core.Vertx; import io.vertx.core.VertxOptions; +import org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory; import org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration; import org.apache.camel.spi.HeaderFilterStrategy; import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon; @@ -617,6 +618,15 @@ public class VertxKafkaComponentConfiguration */ private Vertx vertx; /** + * Factory to use for creating io.vertx.kafka.client.consumer.KafkaConsumer + * and io.vertx.kafka.client.consumer.KafkaProducer instances. This allows + * to configure a custom factory to create custom KafkaConsumer and + * KafkaProducer instances with logic that extends the vanilla VertX Kafka + * clients. The option is a + * org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory type. + */ + private VertxKafkaClientFactory vertxKafkaClientFactory; + /** * To provide a custom set of vertx options for configuring vertx. The * option is a io.vertx.core.VertxOptions type. */ @@ -1382,6 +1392,15 @@ public class VertxKafkaComponentConfiguration this.vertx = vertx; } + public VertxKafkaClientFactory getVertxKafkaClientFactory() { + return vertxKafkaClientFactory; + } + + public void setVertxKafkaClientFactory( + VertxKafkaClientFactory vertxKafkaClientFactory) { + this.vertxKafkaClientFactory = vertxKafkaClientFactory; + } + public VertxOptions getVertxOptions() { return vertxOptions; } diff --git a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConverter.java b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConverter.java index 43a71b7..59df7a25 100644 --- a/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConverter.java +++ b/components-starter/camel-vertx-kafka-starter/src/main/java/org/apache/camel/component/vertx/kafka/springboot/VertxKafkaComponentConverter.java @@ -43,6 +43,7 @@ public class VertxKafkaComponentConverter answer.add(new ConvertiblePair(String.class, org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration.class)); answer.add(new ConvertiblePair(String.class, org.apache.camel.spi.HeaderFilterStrategy.class)); answer.add(new ConvertiblePair(String.class, io.vertx.core.Vertx.class)); + answer.add(new ConvertiblePair(String.class, org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory.class)); answer.add(new ConvertiblePair(String.class, io.vertx.core.VertxOptions.class)); return answer; } @@ -63,6 +64,7 @@ public class VertxKafkaComponentConverter case "org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration": return camelContext.getRegistry().lookupByNameAndType(ref, org.apache.camel.component.vertx.kafka.configuration.VertxKafkaConfiguration.class); case "org.apache.camel.spi.HeaderFilterStrategy": return camelContext.getRegistry().lookupByNameAndType(ref, org.apache.camel.spi.HeaderFilterStrategy.class); case "io.vertx.core.Vertx": return camelContext.getRegistry().lookupByNameAndType(ref, io.vertx.core.Vertx.class); + case "org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory": return camelContext.getRegistry().lookupByNameAndType(ref, org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory.class); case "io.vertx.core.VertxOptions": return camelContext.getRegistry().lookupByNameAndType(ref, io.vertx.core.VertxOptions.class); } return null; diff --git a/docs/modules/ROOT/pages/kafka-starter.adoc b/docs/modules/ROOT/pages/kafka-starter.adoc index 9a031fc..447b47f 100644 --- a/docs/modules/ROOT/pages/kafka-starter.adoc +++ b/docs/modules/ROOT/pages/kafka-starter.adoc @@ -17,7 +17,7 @@ When using kafka with Spring Boot make sure to use the following Maven dependenc ---- -The component supports 99 options, which are listed below. +The component supports 100 options, which are listed below. @@ -54,6 +54,7 @@ The component supports 99 options, which are listed below. | *camel.component.kafka.header-serializer* | To use a custom KafkaHeaderSerializer to serialize kafka headers values. The option is a org.apache.camel.component.kafka.serde.KafkaHeaderSerializer type. | | KafkaHeaderSerializer | *camel.component.kafka.heartbeat-interval-ms* | The expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group. The value must be set lower than session.timeout.ms, but typically should be set no higher than 1/3 of that value. It can be adjusted even lower to control the expected time for normal [...] | *camel.component.kafka.interceptor-classes* | Sets interceptors for producer or consumers. Producer interceptors have to be classes implementing org.apache.kafka.clients.producer.ProducerInterceptor Consumer interceptors have to be classes implementing org.apache.kafka.clients.consumer.ConsumerInterceptor Note that if you use Producer interceptor on a consumer it will throw a class cast exception in runtime | | String +| *camel.component.kafka.kafka-client-factory* | Factory to use for creating org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances. This allows to configure a custom factory to create org.apache.kafka.clients.consumer.KafkaConsumer and org.apache.kafka.clients.producer.KafkaProducer instances with logic that extends the vanilla Kafka clients. The option is a org.apache.camel.component.kafka.KafkaClientFactory type. | | KafkaClientFactory | *camel.component.kafka.kafka-manual-commit-factory* | Factory to use for creating KafkaManualCommit instances. This allows to plugin a custom factory to create custom KafkaManualCommit instances in case special logic is needed when doing manual commits that deviates from the default implementation that comes out of the box. The option is a org.apache.camel.component.kafka.KafkaManualCommitFactory type. | | KafkaManualCommitFactory | *camel.component.kafka.kerberos-before-relogin-min-time* | Login thread sleep time between refresh attempts. | 60000 | Integer | *camel.component.kafka.kerberos-init-cmd* | Kerberos kinit command path. Default is /usr/bin/kinit | /usr/bin/kinit | String diff --git a/docs/modules/ROOT/pages/vertx-kafka-starter.adoc b/docs/modules/ROOT/pages/vertx-kafka-starter.adoc index 8de0c38..ff57de6 100644 --- a/docs/modules/ROOT/pages/vertx-kafka-starter.adoc +++ b/docs/modules/ROOT/pages/vertx-kafka-starter.adoc @@ -17,7 +17,7 @@ When using vertx-kafka with Spring Boot make sure to use the following Maven dep ---- -The component supports 104 options, which are listed below. +The component supports 105 options, which are listed below. @@ -127,6 +127,7 @@ The component supports 104 options, which are listed below. | *camel.component.vertx-kafka.value-deserializer* | Deserializer class for value that implements the org.apache.kafka.common.serialization.Deserializer interface. | org.apache.kafka.common.serialization.StringDeserializer | String | *camel.component.vertx-kafka.value-serializer* | Serializer class for value that implements the org.apache.kafka.common.serialization.Serializer interface. | org.apache.kafka.common.serialization.StringSerializer | String | *camel.component.vertx-kafka.vertx* | To use an existing vertx instead of creating a new instance. The option is a io.vertx.core.Vertx type. | | Vertx +| *camel.component.vertx-kafka.vertx-kafka-client-factory* | Factory to use for creating io.vertx.kafka.client.consumer.KafkaConsumer and io.vertx.kafka.client.consumer.KafkaProducer instances. This allows to configure a custom factory to create custom KafkaConsumer and KafkaProducer instances with logic that extends the vanilla VertX Kafka clients. The option is a org.apache.camel.component.vertx.kafka.VertxKafkaClientFactory type. | | VertxKafkaClientFactory | *camel.component.vertx-kafka.vertx-options* | To provide a custom set of vertx options for configuring vertx. The option is a io.vertx.core.VertxOptions type. | | VertxOptions |=== // spring-boot-auto-configure options: END