This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 0abc1de6bb [create-pull-request] automated change (#1716)
0abc1de6bb is described below
commit 0abc1de6bb07790e8ab4aa6f20805361788ee94e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Apr 21 08:28:17 2025 +0200
[create-pull-request] automated change (#1716)
Co-authored-by: oscerd <5106647+osc...@users.noreply.github.com>
---
.../resources/connectors/camel-netty-http-sink.json | 14 ++++++++++++++
.../resources/connectors/camel-netty-http-source.json | 14 ++++++++++++++
.../generated/resources/connectors/camel-netty-sink.json | 14 ++++++++++++++
.../generated/resources/connectors/camel-netty-source.json | 14 ++++++++++++++
.../src/generated/resources/camel-netty-http-sink.json | 14 ++++++++++++++
.../src/generated/resources/camel-netty-http-source.json | 14 ++++++++++++++
.../nettyhttp/CamelNettyhttpSinkConnectorConfig.java | 8 ++++++++
.../nettyhttp/CamelNettyhttpSourceConnectorConfig.java | 8 ++++++++
.../src/generated/resources/camel-netty-sink.json | 14 ++++++++++++++
.../src/generated/resources/camel-netty-source.json | 14 ++++++++++++++
.../netty/CamelNettySinkConnectorConfig.java | 8 ++++++++
.../netty/CamelNettySourceConnectorConfig.java | 8 ++++++++
connectors/camel-snowflake-sink-kafka-connector/pom.xml | 10 +++++-----
connectors/camel-snowflake-source-kafka-connector/pom.xml | 10 +++++-----
14 files changed, 154 insertions(+), 10 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json
index 9a835e77e1..10c31475cd 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json
@@ -266,6 +266,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.shutdownTimeout": {
+ "name": "camel.sink.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.synchronous": {
"name": "camel.sink.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -613,6 +620,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.shutdownTimeout": {
+ "name": "camel.component.netty-http.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.transferExchange": {
"name": "camel.component.netty-http.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json
index 06d37a6475..102ad7c9f0 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json
@@ -367,6 +367,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.shutdownTimeout": {
+ "name": "camel.source.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.synchronous": {
"name": "camel.source.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -782,6 +789,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.shutdownTimeout": {
+ "name": "camel.component.netty-http.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.transferExchange": {
"name": "camel.component.netty-http.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
index 365a3e0494..2ca9e4001d 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
@@ -220,6 +220,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.shutdownTimeout": {
+ "name": "camel.sink.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.synchronous": {
"name": "camel.sink.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -600,6 +607,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.shutdownTimeout": {
+ "name": "camel.component.netty.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.transferExchange": {
"name": "camel.component.netty.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
index 82cb1ed2b4..5e5c6cf2b3 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
@@ -266,6 +266,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.shutdownTimeout": {
+ "name": "camel.source.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.synchronous": {
"name": "camel.source.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -695,6 +702,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.shutdownTimeout": {
+ "name": "camel.component.netty.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.transferExchange": {
"name": "camel.component.netty.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json
b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json
index 9a835e77e1..10c31475cd 100644
---
a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json
+++
b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json
@@ -266,6 +266,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.shutdownTimeout": {
+ "name": "camel.sink.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.synchronous": {
"name": "camel.sink.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -613,6 +620,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.shutdownTimeout": {
+ "name": "camel.component.netty-http.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.transferExchange": {
"name": "camel.component.netty-http.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json
b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json
index 06d37a6475..102ad7c9f0 100644
---
a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json
+++
b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json
@@ -367,6 +367,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.shutdownTimeout": {
+ "name": "camel.source.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.synchronous": {
"name": "camel.source.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -782,6 +789,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.shutdownTimeout": {
+ "name": "camel.component.netty-http.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.transferExchange": {
"name": "camel.component.netty-http.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
index 68664fb8d3..54924ffa01 100644
---
a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
+++
b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
@@ -140,6 +140,9 @@ public class CamelNettyhttpSinkConnectorConfig
public static final String
CAMEL_SINK_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_CONF =
"camel.sink.endpoint.sendBufferSize";
public static final String
CAMEL_SINK_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes
to be used during outbound communication. Size is bytes.";
public static final Integer
CAMEL_SINK_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String
CAMEL_SINK_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_CONF =
"camel.sink.endpoint.shutdownTimeout";
+ public static final String
CAMEL_SINK_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DOC = "Shutdown await timeout in
milliseconds";
+ public static final Integer
CAMEL_SINK_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_SYNCHRONOUS_CONF
= "camel.sink.endpoint.synchronous";
public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DOC =
"Sets whether synchronous processing should be strictly used";
public static final Boolean
CAMEL_SINK_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DEFAULT = false;
@@ -299,6 +302,9 @@ public class CamelNettyhttpSinkConnectorConfig
public static final String
CAMEL_SINK_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_CONF =
"camel.component.netty-http.sendBufferSize";
public static final String
CAMEL_SINK_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes
to be used during outbound communication. Size is bytes.";
public static final Integer
CAMEL_SINK_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String
CAMEL_SINK_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_CONF =
"camel.component.netty-http.shutdownTimeout";
+ public static final String
CAMEL_SINK_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DOC = "Shutdown await timeout
in milliseconds";
+ public static final Integer
CAMEL_SINK_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String
CAMEL_SINK_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_CONF =
"camel.component.netty-http.transferExchange";
public static final String
CAMEL_SINK_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DOC = "Only used for TCP. You
can transfer the exchange over the wire instead of just the body. The following
fields are transferred: In body, Out body, fault body, In headers, Out headers,
fault headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.";
public static final Boolean
CAMEL_SINK_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DEFAULT = false;
@@ -434,6 +440,7 @@ public class CamelNettyhttpSinkConnectorConfig
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SINK_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_SYNCHRONOUS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_TRANSFER_EXCEPTION_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_NETTYHTTP_ENDPOINT_TRANSFER_EXCEPTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_ENDPOINT_TRANSFER_EXCEPTION_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_NETTYHTTP_ENDPOINT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_ENDPOINT_TRANSFER_EXCHANGE_DOC);
@@ -487,6 +494,7 @@ public class CamelNettyhttpSinkConnectorConfig
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SINK_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_UDP_BYTE_ARRAY_CODEC_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_NETTYHTTP_COMPONENT_UDP_BYTE_ARRAY_CODEC_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_COMPONENT_UDP_BYTE_ARRAY_CODEC_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_NETTYHTTP_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTYHTTP_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DOC);
diff --git
a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
index ed22f66e54..02f9af307a 100644
---
a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
+++
b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
@@ -173,6 +173,9 @@ public class CamelNettyhttpSourceConnectorConfig
public static final String
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_CONF =
"camel.source.endpoint.sendBufferSize";
public static final String
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer
sizes to be used during outbound communication. Size is bytes.";
public static final Integer
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_CONF =
"camel.source.endpoint.shutdownTimeout";
+ public static final String
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DOC = "Shutdown await timeout
in milliseconds";
+ public static final Integer
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SYNCHRONOUS_CONF =
"camel.source.endpoint.synchronous";
public static final String CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DOC
= "Sets whether synchronous processing should be strictly used";
public static final Boolean
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DEFAULT = false;
@@ -353,6 +356,9 @@ public class CamelNettyhttpSourceConnectorConfig
public static final String
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_CONF =
"camel.component.netty-http.sendBufferSize";
public static final String
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer
sizes to be used during outbound communication. Size is bytes.";
public static final Integer
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_CONF =
"camel.component.netty-http.shutdownTimeout";
+ public static final String
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DOC = "Shutdown await timeout
in milliseconds";
+ public static final Integer
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String
CAMEL_SOURCE_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_CONF =
"camel.component.netty-http.transferExchange";
public static final String
CAMEL_SOURCE_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DOC = "Only used for TCP.
You can transfer the exchange over the wire instead of just the body. The
following fields are transferred: In body, Out body, fault body, In headers,
Out headers, fault headers, exchange properties, exchange exception. This
requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at WARN level.";
public static final Boolean
CAMEL_SOURCE_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DEFAULT = false;
@@ -502,6 +508,7 @@ public class CamelNettyhttpSourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SYNCHRONOUS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_SYNCHRONOUS_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRANSFER_EXCEPTION_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRANSFER_EXCEPTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRANSFER_EXCEPTION_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRANSFER_EXCHANGE_DOC);
@@ -562,6 +569,7 @@ public class CamelNettyhttpSourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_UDP_BYTE_ARRAY_CODEC_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_UDP_BYTE_ARRAY_CODEC_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_UDP_BYTE_ARRAY_CODEC_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTYHTTP_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DOC);
diff --git
a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json
b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json
index 365a3e0494..2ca9e4001d 100644
---
a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json
+++
b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json
@@ -220,6 +220,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.shutdownTimeout": {
+ "name": "camel.sink.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.synchronous": {
"name": "camel.sink.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -600,6 +607,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.shutdownTimeout": {
+ "name": "camel.component.netty.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.transferExchange": {
"name": "camel.component.netty.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json
b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json
index 82cb1ed2b4..5e5c6cf2b3 100644
---
a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json
+++
b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json
@@ -266,6 +266,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.shutdownTimeout": {
+ "name": "camel.source.endpoint.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.synchronous": {
"name": "camel.source.endpoint.synchronous",
"description": "Sets whether synchronous processing
should be strictly used",
@@ -695,6 +702,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.shutdownTimeout": {
+ "name": "camel.component.netty.shutdownTimeout",
+ "description": "Shutdown await timeout in milliseconds",
+ "defaultValue": "100",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.transferExchange": {
"name": "camel.component.netty.transferExchange",
"description": "Only used for TCP. You can transfer the
exchange over the wire instead of just the body. The following fields are
transferred: In body, Out body, fault body, In headers, Out headers, fault
headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.",
diff --git
a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java
b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java
index 9f6a301ca8..d957fb5d65 100644
---
a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java
+++
b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java
@@ -117,6 +117,9 @@ public class CamelNettySinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_NETTY_ENDPOINT_SEND_BUFFER_SIZE_CONF
= "camel.sink.endpoint.sendBufferSize";
public static final String CAMEL_SINK_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DOC
= "The TCP/UDP buffer sizes to be used during outbound communication. Size is
bytes.";
public static final Integer
CAMEL_SINK_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String CAMEL_SINK_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_CONF
= "camel.sink.endpoint.shutdownTimeout";
+ public static final String CAMEL_SINK_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DOC
= "Shutdown await timeout in milliseconds";
+ public static final Integer
CAMEL_SINK_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String CAMEL_SINK_NETTY_ENDPOINT_SYNCHRONOUS_CONF =
"camel.sink.endpoint.synchronous";
public static final String CAMEL_SINK_NETTY_ENDPOINT_SYNCHRONOUS_DOC =
"Sets whether synchronous processing should be strictly used";
public static final Boolean CAMEL_SINK_NETTY_ENDPOINT_SYNCHRONOUS_DEFAULT
= false;
@@ -288,6 +291,9 @@ public class CamelNettySinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_NETTY_COMPONENT_SEND_BUFFER_SIZE_CONF =
"camel.component.netty.sendBufferSize";
public static final String CAMEL_SINK_NETTY_COMPONENT_SEND_BUFFER_SIZE_DOC
= "The TCP/UDP buffer sizes to be used during outbound communication. Size is
bytes.";
public static final Integer
CAMEL_SINK_NETTY_COMPONENT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String
CAMEL_SINK_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_CONF =
"camel.component.netty.shutdownTimeout";
+ public static final String CAMEL_SINK_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DOC
= "Shutdown await timeout in milliseconds";
+ public static final Integer
CAMEL_SINK_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String
CAMEL_SINK_NETTY_COMPONENT_TRANSFER_EXCHANGE_CONF =
"camel.component.netty.transferExchange";
public static final String
CAMEL_SINK_NETTY_COMPONENT_TRANSFER_EXCHANGE_DOC = "Only used for TCP. You can
transfer the exchange over the wire instead of just the body. The following
fields are transferred: In body, Out body, fault body, In headers, Out headers,
fault headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.";
public static final Boolean
CAMEL_SINK_NETTY_COMPONENT_TRANSFER_EXCHANGE_DEFAULT = false;
@@ -413,6 +419,7 @@ public class CamelNettySinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SINK_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SINK_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_SYNCHRONOUS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_SYNCHRONOUS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_SYNCHRONOUS_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_TRANSFER_EXCHANGE_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_UDP_BYTE_ARRAY_CODEC_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_UDP_BYTE_ARRAY_CODEC_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTY_ENDPOINT_UDP_BYTE_ARRAY_CODEC_DOC);
@@ -470,6 +477,7 @@ public class CamelNettySinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SINK_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTY_COMPONENT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SINK_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SINK_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_COMPONENT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_TRANSFER_EXCHANGE_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_UDP_BYTE_ARRAY_CODEC_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_NETTY_COMPONENT_UDP_BYTE_ARRAY_CODEC_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTY_COMPONENT_UDP_BYTE_ARRAY_CODEC_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_NETTY_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_NETTY_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DOC);
diff --git
a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java
b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java
index a8b98d96bf..86422f52d5 100644
---
a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java
+++
b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java
@@ -128,6 +128,9 @@ public class CamelNettySourceConnectorConfig
public static final String
CAMEL_SOURCE_NETTY_ENDPOINT_SEND_BUFFER_SIZE_CONF =
"camel.source.endpoint.sendBufferSize";
public static final String
CAMEL_SOURCE_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes to
be used during outbound communication. Size is bytes.";
public static final Integer
CAMEL_SOURCE_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String
CAMEL_SOURCE_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_CONF =
"camel.source.endpoint.shutdownTimeout";
+ public static final String
CAMEL_SOURCE_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DOC = "Shutdown await timeout in
milliseconds";
+ public static final Integer
CAMEL_SOURCE_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String CAMEL_SOURCE_NETTY_ENDPOINT_SYNCHRONOUS_CONF =
"camel.source.endpoint.synchronous";
public static final String CAMEL_SOURCE_NETTY_ENDPOINT_SYNCHRONOUS_DOC =
"Sets whether synchronous processing should be strictly used";
public static final Boolean
CAMEL_SOURCE_NETTY_ENDPOINT_SYNCHRONOUS_DEFAULT = false;
@@ -311,6 +314,9 @@ public class CamelNettySourceConnectorConfig
public static final String
CAMEL_SOURCE_NETTY_COMPONENT_SEND_BUFFER_SIZE_CONF =
"camel.component.netty.sendBufferSize";
public static final String
CAMEL_SOURCE_NETTY_COMPONENT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes
to be used during outbound communication. Size is bytes.";
public static final Integer
CAMEL_SOURCE_NETTY_COMPONENT_SEND_BUFFER_SIZE_DEFAULT = 65536;
+ public static final String
CAMEL_SOURCE_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_CONF =
"camel.component.netty.shutdownTimeout";
+ public static final String
CAMEL_SOURCE_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DOC = "Shutdown await timeout in
milliseconds";
+ public static final Integer
CAMEL_SOURCE_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT = 100;
public static final String
CAMEL_SOURCE_NETTY_COMPONENT_TRANSFER_EXCHANGE_CONF =
"camel.component.netty.transferExchange";
public static final String
CAMEL_SOURCE_NETTY_COMPONENT_TRANSFER_EXCHANGE_DOC = "Only used for TCP. You
can transfer the exchange over the wire instead of just the body. The following
fields are transferred: In body, Out body, fault body, In headers, Out headers,
fault headers, exchange properties, exchange exception. This requires that the
objects are serializable. Camel will exclude any non-serializable objects and
log it at WARN level.";
public static final Boolean
CAMEL_SOURCE_NETTY_COMPONENT_TRANSFER_EXCHANGE_DEFAULT = false;
@@ -442,6 +448,7 @@ public class CamelNettySourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_ENDPOINT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_SYNCHRONOUS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_ENDPOINT_SYNCHRONOUS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_SYNCHRONOUS_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_ENDPOINT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_TRANSFER_EXCHANGE_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_UDP_BYTE_ARRAY_CODEC_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_NETTY_ENDPOINT_UDP_BYTE_ARRAY_CODEC_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_ENDPOINT_UDP_BYTE_ARRAY_CODEC_DOC);
@@ -503,6 +510,7 @@ public class CamelNettySourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_COMPONENT_RECEIVE_BUFFER_SIZE_PREDICTOR_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_SEND_BUFFER_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTY_COMPONENT_SEND_BUFFER_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_SEND_BUFFER_SIZE_DOC);
+ conf.define(CAMEL_SOURCE_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_TRANSFER_EXCHANGE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_COMPONENT_TRANSFER_EXCHANGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_COMPONENT_TRANSFER_EXCHANGE_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_UDP_BYTE_ARRAY_CODEC_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_NETTY_COMPONENT_UDP_BYTE_ARRAY_CODEC_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_COMPONENT_UDP_BYTE_ARRAY_CODEC_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_NETTY_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_NETTY_COMPONENT_UNIX_DOMAIN_SOCKET_PATH_DOC);
diff --git a/connectors/camel-snowflake-sink-kafka-connector/pom.xml
b/connectors/camel-snowflake-sink-kafka-connector/pom.xml
index 565f580bb2..bb2a900796 100644
--- a/connectors/camel-snowflake-sink-kafka-connector/pom.xml
+++ b/connectors/camel-snowflake-sink-kafka-connector/pom.xml
@@ -45,16 +45,16 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-jackson</artifactId>
</dependency>
- <dependency>
- <groupId>org.apache.commons</groupId>
- <artifactId>commons-dbcp2</artifactId>
- <version>2.13.0</version>
- </dependency>
<dependency>
<groupId>net.snowflake</groupId>
<artifactId>snowflake-jdbc</artifactId>
<version>3.22.0</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-dbcp2</artifactId>
+ <version>2.13.0</version>
+ </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-snowflake-source-kafka-connector/pom.xml
b/connectors/camel-snowflake-source-kafka-connector/pom.xml
index ee4fdb1c9e..8e064fd2a5 100644
--- a/connectors/camel-snowflake-source-kafka-connector/pom.xml
+++ b/connectors/camel-snowflake-source-kafka-connector/pom.xml
@@ -45,16 +45,16 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-jackson</artifactId>
</dependency>
- <dependency>
- <groupId>org.apache.commons</groupId>
- <artifactId>commons-dbcp2</artifactId>
- <version>2.13.0</version>
- </dependency>
<dependency>
<groupId>net.snowflake</groupId>
<artifactId>snowflake-jdbc</artifactId>
<version>3.22.0</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-dbcp2</artifactId>
+ <version>2.13.0</version>
+ </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
