You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2020/10/06 01:38:43 UTC

[camel-kafka-connector] 05/08: [create-pull-request] automated change

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit d3ea257dc39c21ef8aa485243b7902a4097f3ee5
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Fri Oct 2 03:43:14 2020 +0000

    [create-pull-request] automated change
---
 .../camel-infinispan-kafka-sink-connector.adoc     | 10 ++++++-
 .../CamelInfinispanSinkConnectorConfig.java        | 32 ++++++++++++++++++++++
 .../camel-infinispan-kafka-sink-connector.adoc     | 10 ++++++-
 3 files changed, 50 insertions(+), 2 deletions(-)

diff --git a/connectors/camel-infinispan-kafka-connector/src/main/docs/camel-infinispan-kafka-sink-connector.adoc b/connectors/camel-infinispan-kafka-connector/src/main/docs/camel-infinispan-kafka-sink-connector.adoc
index 7d75545..09f95f8 100644
--- a/connectors/camel-infinispan-kafka-connector/src/main/docs/camel-infinispan-kafka-sink-connector.adoc
+++ b/connectors/camel-infinispan-kafka-connector/src/main/docs/camel-infinispan-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@ connector.class=org.apache.camel.kafkaconnector.infinispan.CamelInfinispanSinkCo
 ----
 
 
-The camel-infinispan sink connector supports 27 options, which are listed below.
+The camel-infinispan sink connector supports 35 options, which are listed below.
 
 
 
@@ -32,8 +32,12 @@ The camel-infinispan sink connector supports 27 options, which are listed below.
 | *camel.sink.path.cacheName* | The name of the cache to use. Use current to use the existing cache name from the currently configured cached manager. Or use default for the default cache manager name. | null | HIGH
 | *camel.sink.endpoint.hosts* | Specifies the host of the cache on Infinispan instance | null | MEDIUM
 | *camel.sink.endpoint.queryBuilder* | Specifies the query builder. | null | MEDIUM
+| *camel.sink.endpoint.defaultValue* | Set a specific default value for some producer operations | null | MEDIUM
+| *camel.sink.endpoint.key* | Set a specific key for producer operations | null | MEDIUM
 | *camel.sink.endpoint.lazyStartProducer* | 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 starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then cre [...]
+| *camel.sink.endpoint.oldValue* | Set a specific old value for some producer operations | null | MEDIUM
 | *camel.sink.endpoint.operation* | The operation to perform. One of: [PUT] [PUTASYNC] [PUTALL] [PUTALLASYNC] [PUTIFABSENT] [PUTIFABSENTASYNC] [GET] [GETORDEFAULT] [CONTAINSKEY] [CONTAINSVALUE] [REMOVE] [REMOVEASYNC] [REPLACE] [REPLACEASYNC] [SIZE] [CLEAR] [CLEARASYNC] [QUERY] [STATS] [COMPUTE] [COMPUTEASYNC] | "PUT" | MEDIUM
+| *camel.sink.endpoint.value* | Set a specific value for producer operations | null | MEDIUM
 | *camel.sink.endpoint.basicPropertyBinding* | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | MEDIUM
 | *camel.sink.endpoint.cacheContainer* | Specifies the cache Container to connect | null | MEDIUM
 | *camel.sink.endpoint.cacheContainerConfiguration* | The CacheContainer configuration. Uses if the cacheContainer is not defined. Must be the following types: org.infinispan.client.hotrod.configuration.Configuration - for remote cache interaction configuration; org.infinispan.configuration.cache.Configuration - for embedded cache interaction configuration; | null | MEDIUM
@@ -46,8 +50,12 @@ The camel-infinispan sink connector supports 27 options, which are listed below.
 | *camel.component.infinispan.configuration* | Component configuration | null | MEDIUM
 | *camel.component.infinispan.hosts* | Specifies the host of the cache on Infinispan instance | null | MEDIUM
 | *camel.component.infinispan.queryBuilder* | Specifies the query builder. | null | MEDIUM
+| *camel.component.infinispan.defaultValue* | Set a specific default value for some producer operations | null | MEDIUM
+| *camel.component.infinispan.key* | Set a specific key for producer operations | null | MEDIUM
 | *camel.component.infinispan.lazyStartProducer* | 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 starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed t [...]
+| *camel.component.infinispan.oldValue* | Set a specific old value for some producer operations | null | MEDIUM
 | *camel.component.infinispan.operation* | The operation to perform. One of: [PUT] [PUTASYNC] [PUTALL] [PUTALLASYNC] [PUTIFABSENT] [PUTIFABSENTASYNC] [GET] [GETORDEFAULT] [CONTAINSKEY] [CONTAINSVALUE] [REMOVE] [REMOVEASYNC] [REPLACE] [REPLACEASYNC] [SIZE] [CLEAR] [CLEARASYNC] [QUERY] [STATS] [COMPUTE] [COMPUTEASYNC] | "PUT" | MEDIUM
+| *camel.component.infinispan.value* | Set a specific value for producer operations | null | MEDIUM
 | *camel.component.infinispan.basicPropertyBinding* | Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | LOW
 | *camel.component.infinispan.cacheContainer* | Specifies the cache Container to connect | null | MEDIUM
 | *camel.component.infinispan.cacheContainer Configuration* | The CacheContainer configuration. Uses if the cacheContainer is not defined. Must be the following types: org.infinispan.client.hotrod.configuration.Configuration - for remote cache interaction configuration; org.infinispan.configuration.cache.Configuration - for embedded cache interaction configuration; | null | MEDIUM
diff --git a/connectors/camel-infinispan-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispan/CamelInfinispanSinkConnectorConfig.java b/connectors/camel-infinispan-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispan/CamelInfinispanSinkConnectorConfig.java
index f12fd95..666617f 100644
--- a/connectors/camel-infinispan-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispan/CamelInfinispanSinkConnectorConfig.java
+++ b/connectors/camel-infinispan-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispan/CamelInfinispanSinkConnectorConfig.java
@@ -35,12 +35,24 @@ public class CamelInfinispanSinkConnectorConfig
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_QUERY_BUILDER_CONF = "camel.sink.endpoint.queryBuilder";
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_QUERY_BUILDER_DOC = "Specifies the query builder.";
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_QUERY_BUILDER_DEFAULT = null;
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_DEFAULT_VALUE_CONF = "camel.sink.endpoint.defaultValue";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_DEFAULT_VALUE_DOC = "Set a specific default value for some producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_DEFAULT_VALUE_DEFAULT = null;
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_KEY_CONF = "camel.sink.endpoint.key";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_KEY_DOC = "Set a specific key for producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_KEY_DEFAULT = null;
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer";
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_LAZY_START_PRODUCER_DOC = "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 starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that [...]
     public static final Boolean CAMEL_SINK_INFINISPAN_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_OLD_VALUE_CONF = "camel.sink.endpoint.oldValue";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_OLD_VALUE_DOC = "Set a specific old value for some producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_OLD_VALUE_DEFAULT = null;
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_OPERATION_CONF = "camel.sink.endpoint.operation";
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_OPERATION_DOC = "The operation to perform. One of: [PUT] [PUTASYNC] [PUTALL] [PUTALLASYNC] [PUTIFABSENT] [PUTIFABSENTASYNC] [GET] [GETORDEFAULT] [CONTAINSKEY] [CONTAINSVALUE] [REMOVE] [REMOVEASYNC] [REPLACE] [REPLACEASYNC] [SIZE] [CLEAR] [CLEARASYNC] [QUERY] [STATS] [COMPUTE] [COMPUTEASYNC]";
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_OPERATION_DEFAULT = "PUT";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_VALUE_CONF = "camel.sink.endpoint.value";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_VALUE_DOC = "Set a specific value for producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_VALUE_DEFAULT = null;
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_BASIC_PROPERTY_BINDING_CONF = "camel.sink.endpoint.basicPropertyBinding";
     public static final String CAMEL_SINK_INFINISPAN_ENDPOINT_BASIC_PROPERTY_BINDING_DOC = "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities";
     public static final Boolean CAMEL_SINK_INFINISPAN_ENDPOINT_BASIC_PROPERTY_BINDING_DEFAULT = false;
@@ -77,12 +89,24 @@ public class CamelInfinispanSinkConnectorConfig
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_QUERY_BUILDER_CONF = "camel.component.infinispan.queryBuilder";
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_QUERY_BUILDER_DOC = "Specifies the query builder.";
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_QUERY_BUILDER_DEFAULT = null;
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_DEFAULT_VALUE_CONF = "camel.component.infinispan.defaultValue";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_DEFAULT_VALUE_DOC = "Set a specific default value for some producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_DEFAULT_VALUE_DEFAULT = null;
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_KEY_CONF = "camel.component.infinispan.key";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_KEY_DOC = "Set a specific key for producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_KEY_DEFAULT = null;
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_LAZY_START_PRODUCER_CONF = "camel.component.infinispan.lazyStartProducer";
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_LAZY_START_PRODUCER_DOC = "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 starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware tha [...]
     public static final Boolean CAMEL_SINK_INFINISPAN_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_OLD_VALUE_CONF = "camel.component.infinispan.oldValue";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_OLD_VALUE_DOC = "Set a specific old value for some producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_OLD_VALUE_DEFAULT = null;
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_OPERATION_CONF = "camel.component.infinispan.operation";
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_OPERATION_DOC = "The operation to perform. One of: [PUT] [PUTASYNC] [PUTALL] [PUTALLASYNC] [PUTIFABSENT] [PUTIFABSENTASYNC] [GET] [GETORDEFAULT] [CONTAINSKEY] [CONTAINSVALUE] [REMOVE] [REMOVEASYNC] [REPLACE] [REPLACEASYNC] [SIZE] [CLEAR] [CLEARASYNC] [QUERY] [STATS] [COMPUTE] [COMPUTEASYNC]";
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_OPERATION_DEFAULT = "PUT";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_VALUE_CONF = "camel.component.infinispan.value";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_VALUE_DOC = "Set a specific value for producer operations";
+    public static final String CAMEL_SINK_INFINISPAN_COMPONENT_VALUE_DEFAULT = null;
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_BASIC_PROPERTY_BINDING_CONF = "camel.component.infinispan.basicPropertyBinding";
     public static final String CAMEL_SINK_INFINISPAN_COMPONENT_BASIC_PROPERTY_BINDING_DOC = "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities";
     public static final Boolean CAMEL_SINK_INFINISPAN_COMPONENT_BASIC_PROPERTY_BINDING_DEFAULT = false;
@@ -123,8 +147,12 @@ public class CamelInfinispanSinkConnectorConfig
         conf.define(CAMEL_SINK_INFINISPAN_PATH_CACHE_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_PATH_CACHE_NAME_DEFAULT, ConfigDef.Importance.HIGH, CAMEL_SINK_INFINISPAN_PATH_CACHE_NAME_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_HOSTS_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_HOSTS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_HOSTS_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_QUERY_BUILDER_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_QUERY_BUILDER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_QUERY_BUILDER_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_DEFAULT_VALUE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_DEFAULT_VALUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_DEFAULT_VALUE_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_KEY_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_KEY_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_LAZY_START_PRODUCER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_INFINISPAN_ENDPOINT_LAZY_START_PRODUCER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_LAZY_START_PRODUCER_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_OLD_VALUE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_OLD_VALUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_OLD_VALUE_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_OPERATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_OPERATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_OPERATION_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_VALUE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_VALUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_VALUE_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_BASIC_PROPERTY_BINDING_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_INFINISPAN_ENDPOINT_BASIC_PROPERTY_BINDING_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_BASIC_PROPERTY_BINDING_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_CACHE_CONTAINER_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_CACHE_CONTAINER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_CACHE_CONTAINER_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_ENDPOINT_CACHE_CONTAINER_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_ENDPOINT_CACHE_CONTAINER_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_ENDPOINT_CACHE_CONTAINER_CONFIGURATION_DOC);
@@ -137,8 +165,12 @@ public class CamelInfinispanSinkConnectorConfig
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_CONFIGURATION_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_HOSTS_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_HOSTS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_HOSTS_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_QUERY_BUILDER_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_QUERY_BUILDER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_QUERY_BUILDER_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_DEFAULT_VALUE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_DEFAULT_VALUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_DEFAULT_VALUE_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_KEY_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_KEY_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_LAZY_START_PRODUCER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_INFINISPAN_COMPONENT_LAZY_START_PRODUCER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_LAZY_START_PRODUCER_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_OLD_VALUE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_OLD_VALUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_OLD_VALUE_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_OPERATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_OPERATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_OPERATION_DOC);
+        conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_VALUE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_VALUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_VALUE_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_BASIC_PROPERTY_BINDING_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_INFINISPAN_COMPONENT_BASIC_PROPERTY_BINDING_DEFAULT, ConfigDef.Importance.LOW, CAMEL_SINK_INFINISPAN_COMPONENT_BASIC_PROPERTY_BINDING_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_CACHE_CONTAINER_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_CACHE_CONTAINER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_CACHE_CONTAINER_DOC);
         conf.define(CAMEL_SINK_INFINISPAN_COMPONENT_CACHE_CONTAINER_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_INFINISPAN_COMPONENT_CACHE_CONTAINER_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_INFINISPAN_COMPONENT_CACHE_CONTAINER_CONFIGURATION_DOC);
diff --git a/docs/modules/ROOT/pages/connectors/camel-infinispan-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-infinispan-kafka-sink-connector.adoc
index 7d75545..09f95f8 100644
--- a/docs/modules/ROOT/pages/connectors/camel-infinispan-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-infinispan-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@ connector.class=org.apache.camel.kafkaconnector.infinispan.CamelInfinispanSinkCo
 ----
 
 
-The camel-infinispan sink connector supports 27 options, which are listed below.
+The camel-infinispan sink connector supports 35 options, which are listed below.
 
 
 
@@ -32,8 +32,12 @@ The camel-infinispan sink connector supports 27 options, which are listed below.
 | *camel.sink.path.cacheName* | The name of the cache to use. Use current to use the existing cache name from the currently configured cached manager. Or use default for the default cache manager name. | null | HIGH
 | *camel.sink.endpoint.hosts* | Specifies the host of the cache on Infinispan instance | null | MEDIUM
 | *camel.sink.endpoint.queryBuilder* | Specifies the query builder. | null | MEDIUM
+| *camel.sink.endpoint.defaultValue* | Set a specific default value for some producer operations | null | MEDIUM
+| *camel.sink.endpoint.key* | Set a specific key for producer operations | null | MEDIUM
 | *camel.sink.endpoint.lazyStartProducer* | 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 starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then cre [...]
+| *camel.sink.endpoint.oldValue* | Set a specific old value for some producer operations | null | MEDIUM
 | *camel.sink.endpoint.operation* | The operation to perform. One of: [PUT] [PUTASYNC] [PUTALL] [PUTALLASYNC] [PUTIFABSENT] [PUTIFABSENTASYNC] [GET] [GETORDEFAULT] [CONTAINSKEY] [CONTAINSVALUE] [REMOVE] [REMOVEASYNC] [REPLACE] [REPLACEASYNC] [SIZE] [CLEAR] [CLEARASYNC] [QUERY] [STATS] [COMPUTE] [COMPUTEASYNC] | "PUT" | MEDIUM
+| *camel.sink.endpoint.value* | Set a specific value for producer operations | null | MEDIUM
 | *camel.sink.endpoint.basicPropertyBinding* | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | MEDIUM
 | *camel.sink.endpoint.cacheContainer* | Specifies the cache Container to connect | null | MEDIUM
 | *camel.sink.endpoint.cacheContainerConfiguration* | The CacheContainer configuration. Uses if the cacheContainer is not defined. Must be the following types: org.infinispan.client.hotrod.configuration.Configuration - for remote cache interaction configuration; org.infinispan.configuration.cache.Configuration - for embedded cache interaction configuration; | null | MEDIUM
@@ -46,8 +50,12 @@ The camel-infinispan sink connector supports 27 options, which are listed below.
 | *camel.component.infinispan.configuration* | Component configuration | null | MEDIUM
 | *camel.component.infinispan.hosts* | Specifies the host of the cache on Infinispan instance | null | MEDIUM
 | *camel.component.infinispan.queryBuilder* | Specifies the query builder. | null | MEDIUM
+| *camel.component.infinispan.defaultValue* | Set a specific default value for some producer operations | null | MEDIUM
+| *camel.component.infinispan.key* | Set a specific key for producer operations | null | MEDIUM
 | *camel.component.infinispan.lazyStartProducer* | 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 starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed t [...]
+| *camel.component.infinispan.oldValue* | Set a specific old value for some producer operations | null | MEDIUM
 | *camel.component.infinispan.operation* | The operation to perform. One of: [PUT] [PUTASYNC] [PUTALL] [PUTALLASYNC] [PUTIFABSENT] [PUTIFABSENTASYNC] [GET] [GETORDEFAULT] [CONTAINSKEY] [CONTAINSVALUE] [REMOVE] [REMOVEASYNC] [REPLACE] [REPLACEASYNC] [SIZE] [CLEAR] [CLEARASYNC] [QUERY] [STATS] [COMPUTE] [COMPUTEASYNC] | "PUT" | MEDIUM
+| *camel.component.infinispan.value* | Set a specific value for producer operations | null | MEDIUM
 | *camel.component.infinispan.basicPropertyBinding* | Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | LOW
 | *camel.component.infinispan.cacheContainer* | Specifies the cache Container to connect | null | MEDIUM
 | *camel.component.infinispan.cacheContainer Configuration* | The CacheContainer configuration. Uses if the cacheContainer is not defined. Must be the following types: org.infinispan.client.hotrod.configuration.Configuration - for remote cache interaction configuration; org.infinispan.configuration.cache.Configuration - for embedded cache interaction configuration; | null | MEDIUM