diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-https-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-https-sink.json index 9d5c783f52..4104894451 100644 --- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-https-sink.json +++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-https-sink.json @@ -346,6 +346,27 @@ "priority": "MEDIUM", "required": "false" }, + "camel.sink.endpoint.oauth2CachedTokensDefaultExpirySeconds": { + "name": "camel.sink.endpoint.oauth2CachedTokensDefaultExpirySeconds", + "description": "Default expiration time for cached OAuth2 tokens, in seconds. Used if token response does not contain 'expires_in' field.", + "defaultValue": "3600L", + "priority": "MEDIUM", + "required": "false" + }, + "camel.sink.endpoint.oauth2CachedTokensExpirationMarginSeconds": { + "name": "camel.sink.endpoint.oauth2CachedTokensExpirationMarginSeconds", + "description": "Amount of time which is deducted from OAuth2 tokens expiry time to compensate for the time it takes OAuth2 Token Endpoint to send the token over http, in seconds. Set this parameter to high value if you OAuth2 Token Endpoint answers slowly or you tokens expire quickly. If you set this parameter to too small value, you can get 4xx http errors because camel will think that the received token is still valid, while in reality the token is expired for the Authentication server.", + "defaultValue": "5L", + "priority": "MEDIUM", + "required": "false" + }, + "camel.sink.endpoint.oauth2CacheTokens": { + "name": "camel.sink.endpoint.oauth2CacheTokens", + "description": "Whether to cache OAuth2 client tokens.", + "defaultValue": "false", + "priority": "MEDIUM", + "required": "false" + }, "camel.sink.endpoint.oauth2ClientId": { "name": "camel.sink.endpoint.oauth2ClientId", "description": "OAuth2 client id", 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 c4b5818a3e..10e9cdd60f 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 @@ -163,7 +163,7 @@ }, "camel.sink.endpoint.producerPoolMaxTotal": { "name": "camel.sink.endpoint.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" @@ -509,7 +509,7 @@ }, "camel.component.netty-http.producerPoolMaxTotal": { "name": "camel.component.netty-http.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" 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 187e38e90e..d3647ae2da 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 @@ -135,7 +135,7 @@ }, "camel.sink.endpoint.producerPoolMaxTotal": { "name": "camel.sink.endpoint.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" @@ -508,7 +508,7 @@ }, "camel.component.netty.producerPoolMaxTotal": { "name": "camel.component.netty.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" diff --git a/connectors/camel-aws-redshift-sink-kafka-connector/pom.xml b/connectors/camel-aws-redshift-sink-kafka-connector/pom.xml index ce6f1787a9..8bcc18e35a 100644 --- a/connectors/camel-aws-redshift-sink-kafka-connector/pom.xml +++ b/connectors/camel-aws-redshift-sink-kafka-connector/pom.xml @@ -62,15 +62,15 @@ commons-dbcp2 2.12.0 - - com.amazon.redshift - redshift-jdbc42 - 2.1.0.30 - org.apache.camel camel-kamelet + + com.amazon.redshift + redshift-jdbc42 + 2.1.0.31 + diff --git a/connectors/camel-aws-redshift-sink-kafka-connector/src/main/resources/kamelets/aws-redshift-sink.kamelet.yaml b/connectors/camel-aws-redshift-sink-kafka-connector/src/main/resources/kamelets/aws-redshift-sink.kamelet.yaml index 4c8e1101a6..e71fa0c428 100644 --- a/connectors/camel-aws-redshift-sink-kafka-connector/src/main/resources/kamelets/aws-redshift-sink.kamelet.yaml +++ b/connectors/camel-aws-redshift-sink-kafka-connector/src/main/resources/kamelets/aws-redshift-sink.kamelet.yaml @@ -87,10 +87,14 @@ spec: - "camel:jackson" - "camel:kamelet" - "camel:sql" - - "mvn:com.amazon.redshift:redshift-jdbc42:2.1.0.30" + - "mvn:com.amazon.redshift:redshift-jdbc42:2.1.0.31" - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-redshift-sink + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -105,6 +109,6 @@ spec: json: library: Jackson - to: - uri: "sql:{{query}}" + uri: "{{local-sql-redshift-sink}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" \ No newline at end of file diff --git a/connectors/camel-aws-redshift-source-kafka-connector/pom.xml b/connectors/camel-aws-redshift-source-kafka-connector/pom.xml index de3a5791ba..9a8244ef33 100644 --- a/connectors/camel-aws-redshift-source-kafka-connector/pom.xml +++ b/connectors/camel-aws-redshift-source-kafka-connector/pom.xml @@ -62,15 +62,15 @@ commons-dbcp2 2.12.0 - - com.amazon.redshift - redshift-jdbc42 - 2.1.0.30 - org.apache.camel camel-kamelet + + com.amazon.redshift + redshift-jdbc42 + 2.1.0.31 + diff --git a/connectors/camel-aws-redshift-source-kafka-connector/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml b/connectors/camel-aws-redshift-source-kafka-connector/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml index 34e7b26a15..8d87c1a869 100644 --- a/connectors/camel-aws-redshift-source-kafka-connector/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml +++ b/connectors/camel-aws-redshift-source-kafka-connector/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml @@ -89,10 +89,14 @@ spec: - "camel:jackson" - "camel:kamelet" - "camel:sql" - - "mvn:com.amazon.redshift:redshift-jdbc42:2.1.0.30" + - "mvn:com.amazon.redshift:redshift-jdbc42:2.1.0.31" - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-redshift-source + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -101,7 +105,7 @@ spec: url: 'jdbc:redshift://{{serverName}}:{{serverPort}}/{{databaseName}}' driverClassName: 'com.amazon.redshift.jdbc.Driver' from: - uri: "sql:{{query}}" + uri: "{{local-sql-redshift-source}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" onConsume: "{{?consumedQuery}}" diff --git a/connectors/camel-cassandra-sink-kafka-connector/src/main/resources/kamelets/cassandra-sink.kamelet.yaml b/connectors/camel-cassandra-sink-kafka-connector/src/main/resources/kamelets/cassandra-sink.kamelet.yaml index 0de3b2dc7e..5993f7210a 100644 --- a/connectors/camel-cassandra-sink-kafka-connector/src/main/resources/kamelets/cassandra-sink.kamelet.yaml +++ b/connectors/camel-cassandra-sink-kafka-connector/src/main/resources/kamelets/cassandra-sink.kamelet.yaml @@ -103,6 +103,11 @@ spec: - "camel:cassandraql" - "camel:core" template: + beans: + - name: local-sql-cassandraql-sink + type: "#class:org.apache.camel.component.cassandra.CassandraComponent" + properties: + autowiredEnabled: "false" from: uri: "kamelet:source" steps: @@ -116,7 +121,7 @@ spec: library: Jackson useList: true - to: - uri: "cql://{{connectionHost}}:{{connectionPort}}/{{keyspace}}" + uri: "{{local-sql-cassandraql-sink}}://{{connectionHost}}:{{connectionPort}}/{{keyspace}}" parameters: username: "{{?username}}" password: "{{?password}}" diff --git a/connectors/camel-cassandra-source-kafka-connector/src/main/resources/kamelets/cassandra-source.kamelet.yaml b/connectors/camel-cassandra-source-kafka-connector/src/main/resources/kamelets/cassandra-source.kamelet.yaml index de293ddd89..9ee586a0db 100644 --- a/connectors/camel-cassandra-source-kafka-connector/src/main/resources/kamelets/cassandra-source.kamelet.yaml +++ b/connectors/camel-cassandra-source-kafka-connector/src/main/resources/kamelets/cassandra-source.kamelet.yaml @@ -96,8 +96,13 @@ spec: - "camel:kamelet" - "camel:cassandraql" template: + beans: + - name: local-sql-cassandraql-source + type: "#class:org.apache.camel.component.cassandra.CassandraComponent" + properties: + autowiredEnabled: "false" from: - uri: "cql://{{connectionHost}}:{{connectionPort}}/{{keyspace}}" + uri: "{{local-sql-cassandraql-source}}://{{connectionHost}}:{{connectionPort}}/{{keyspace}}" parameters: username: "{{?username}}" password: "{{?password}}" diff --git a/connectors/camel-https-kafka-connector/src/generated/resources/camel-https-sink.json b/connectors/camel-https-kafka-connector/src/generated/resources/camel-https-sink.json index 9d5c783f52..4104894451 100644 --- a/connectors/camel-https-kafka-connector/src/generated/resources/camel-https-sink.json +++ b/connectors/camel-https-kafka-connector/src/generated/resources/camel-https-sink.json @@ -346,6 +346,27 @@ "priority": "MEDIUM", "required": "false" }, + "camel.sink.endpoint.oauth2CachedTokensDefaultExpirySeconds": { + "name": "camel.sink.endpoint.oauth2CachedTokensDefaultExpirySeconds", + "description": "Default expiration time for cached OAuth2 tokens, in seconds. Used if token response does not contain 'expires_in' field.", + "defaultValue": "3600L", + "priority": "MEDIUM", + "required": "false" + }, + "camel.sink.endpoint.oauth2CachedTokensExpirationMarginSeconds": { + "name": "camel.sink.endpoint.oauth2CachedTokensExpirationMarginSeconds", + "description": "Amount of time which is deducted from OAuth2 tokens expiry time to compensate for the time it takes OAuth2 Token Endpoint to send the token over http, in seconds. Set this parameter to high value if you OAuth2 Token Endpoint answers slowly or you tokens expire quickly. If you set this parameter to too small value, you can get 4xx http errors because camel will think that the received token is still valid, while in reality the token is expired for the Authentication server.", + "defaultValue": "5L", + "priority": "MEDIUM", + "required": "false" + }, + "camel.sink.endpoint.oauth2CacheTokens": { + "name": "camel.sink.endpoint.oauth2CacheTokens", + "description": "Whether to cache OAuth2 client tokens.", + "defaultValue": "false", + "priority": "MEDIUM", + "required": "false" + }, "camel.sink.endpoint.oauth2ClientId": { "name": "camel.sink.endpoint.oauth2ClientId", "description": "OAuth2 client id", diff --git a/connectors/camel-https-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/https/CamelHttpsSinkConnectorConfig.java b/connectors/camel-https-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/https/CamelHttpsSinkConnectorConfig.java index 458ef49681..aa2aacf517 100644 --- a/connectors/camel-https-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/https/CamelHttpsSinkConnectorConfig.java +++ b/connectors/camel-https-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/https/CamelHttpsSinkConnectorConfig.java @@ -171,6 +171,15 @@ public class CamelHttpsSinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_HTTPS_ENDPOINT_AUTH_USERNAME_CONF = "camel.sink.endpoint.authUsername"; public static final String CAMEL_SINK_HTTPS_ENDPOINT_AUTH_USERNAME_DOC = "Authentication username"; public static final String CAMEL_SINK_HTTPS_ENDPOINT_AUTH_USERNAME_DEFAULT = null; + public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_DEFAULT_EXPIRY_SECONDS_CONF = "camel.sink.endpoint.oauth2CachedTokensDefaultExpirySeconds"; + public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_DEFAULT_EXPIRY_SECONDS_DOC = "Default expiration time for cached OAuth2 tokens, in seconds. Used if token response does not contain 'expires_in' field."; + public static final Long CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_DEFAULT_EXPIRY_SECONDS_DEFAULT = 3600L; + public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_EXPIRATION_MARGIN_SECONDS_CONF = "camel.sink.endpoint.oauth2CachedTokensExpirationMarginSeconds"; + public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_EXPIRATION_MARGIN_SECONDS_DOC = "Amount of time which is deducted from OAuth2 tokens expiry time to compensate for the time it takes OAuth2 Token Endpoint to send the token over http, in seconds. Set this parameter to high value if you OAuth2 Token Endpoint answers slowly or you tokens expire quickly. If you set this parameter to too small value, you can get 4xx http errors because camel will think that the received token is still valid, while in reality the token is expired for the Authentication server."; + public static final Long CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_EXPIRATION_MARGIN_SECONDS_DEFAULT = 5L; + public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHE_TOKENS_CONF = "camel.sink.endpoint.oauth2CacheTokens"; + public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHE_TOKENS_DOC = "Whether to cache OAuth2 client tokens."; + public static final Boolean CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHE_TOKENS_DEFAULT = false; public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_ID_CONF = "camel.sink.endpoint.oauth2ClientId"; public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_ID_DOC = "OAuth2 client id"; public static final String CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_ID_DEFAULT = null; @@ -371,6 +380,9 @@ public static ConfigDef conf() { conf.define(CAMEL_SINK_HTTPS_ENDPOINT_AUTH_METHOD_PRIORITY_CONF, ConfigDef.Type.STRING, CAMEL_SINK_HTTPS_ENDPOINT_AUTH_METHOD_PRIORITY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_AUTH_METHOD_PRIORITY_DOC); conf.define(CAMEL_SINK_HTTPS_ENDPOINT_AUTH_PASSWORD_CONF, ConfigDef.Type.PASSWORD, CAMEL_SINK_HTTPS_ENDPOINT_AUTH_PASSWORD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_AUTH_PASSWORD_DOC); conf.define(CAMEL_SINK_HTTPS_ENDPOINT_AUTH_USERNAME_CONF, ConfigDef.Type.PASSWORD, CAMEL_SINK_HTTPS_ENDPOINT_AUTH_USERNAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_AUTH_USERNAME_DOC); + conf.define(CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_DEFAULT_EXPIRY_SECONDS_CONF, ConfigDef.Type.LONG, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_DEFAULT_EXPIRY_SECONDS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_DEFAULT_EXPIRY_SECONDS_DOC); + conf.define(CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_EXPIRATION_MARGIN_SECONDS_CONF, ConfigDef.Type.LONG, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_EXPIRATION_MARGIN_SECONDS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHED_TOKENS_EXPIRATION_MARGIN_SECONDS_DOC); + conf.define(CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHE_TOKENS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHE_TOKENS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CACHE_TOKENS_DOC); conf.define(CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_ID_CONF, ConfigDef.Type.PASSWORD, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_ID_DOC); conf.define(CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_SECRET_CONF, ConfigDef.Type.PASSWORD, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_SECRET_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2CLIENT_SECRET_DOC); conf.define(CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2SCOPE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2SCOPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_HTTPS_ENDPOINT_OAUTH_2SCOPE_DOC); diff --git a/connectors/camel-jms-apache-artemis-sink-kafka-connector/pom.xml b/connectors/camel-jms-apache-artemis-sink-kafka-connector/pom.xml index 4fb303b8b6..bfac78dee3 100644 --- a/connectors/camel-jms-apache-artemis-sink-kafka-connector/pom.xml +++ b/connectors/camel-jms-apache-artemis-sink-kafka-connector/pom.xml @@ -44,7 +44,7 @@ org.apache.activemq artemis-jakarta-client-all - 2.37.0 + 2.38.0 org.apache.camel.kafkaconnector diff --git a/connectors/camel-jms-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml b/connectors/camel-jms-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml index 042176f886..41f5ddd220 100644 --- a/connectors/camel-jms-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml +++ b/connectors/camel-jms-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml @@ -55,7 +55,7 @@ spec: dependencies: - "camel:jms" - "camel:kamelet" - - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.37.0" + - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.38.0" template: beans: - name: connectionFactoryBean diff --git a/connectors/camel-jms-apache-artemis-source-kafka-connector/pom.xml b/connectors/camel-jms-apache-artemis-source-kafka-connector/pom.xml index 9e475f8f51..aabd2a0fe7 100644 --- a/connectors/camel-jms-apache-artemis-source-kafka-connector/pom.xml +++ b/connectors/camel-jms-apache-artemis-source-kafka-connector/pom.xml @@ -44,7 +44,7 @@ org.apache.activemq artemis-jakarta-client-all - 2.37.0 + 2.38.0 org.apache.camel.kafkaconnector diff --git a/connectors/camel-jms-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml b/connectors/camel-jms-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml index fa6a6caefd..9637e03dfc 100644 --- a/connectors/camel-jms-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml +++ b/connectors/camel-jms-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml @@ -54,7 +54,7 @@ spec: dependencies: - "camel:jms" - "camel:kamelet" - - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.37.0" + - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.38.0" template: beans: - name: connectionFactoryBean diff --git a/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/pom.xml b/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/pom.xml index 3c03b338f2..fcc6f66180 100644 --- a/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/pom.xml +++ b/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/pom.xml @@ -49,7 +49,7 @@ org.apache.activemq artemis-jakarta-client-all - 2.37.0 + 2.38.0 org.apache.camel.kafkaconnector diff --git a/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml b/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml index 37a7cf164b..a9cfe9ba9a 100644 --- a/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml +++ b/connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml @@ -86,7 +86,7 @@ spec: dependencies: - "camel:jms" - "camel:kamelet" - - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.37.0" + - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.38.0" - "mvn:org.messaginghub:pooled-jms:3.1.7" template: beans: diff --git a/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/pom.xml b/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/pom.xml index 5200ee1110..6392dc4ccb 100644 --- a/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/pom.xml +++ b/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/pom.xml @@ -49,7 +49,7 @@ org.apache.activemq artemis-jakarta-client-all - 2.37.0 + 2.38.0 org.apache.camel.kafkaconnector diff --git a/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml b/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml index f5d7af196b..995566c832 100644 --- a/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml +++ b/connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml @@ -85,7 +85,7 @@ spec: dependencies: - "camel:jms" - "camel:kamelet" - - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.37.0" + - "mvn:org.apache.activemq:artemis-jakarta-client-all:2.38.0" - "mvn:org.messaginghub:pooled-jms:3.1.7" template: beans: diff --git a/connectors/camel-mariadb-sink-kafka-connector/src/main/resources/kamelets/mariadb-sink.kamelet.yaml b/connectors/camel-mariadb-sink-kafka-connector/src/main/resources/kamelets/mariadb-sink.kamelet.yaml index 3d5b334706..3fdf84529c 100644 --- a/connectors/camel-mariadb-sink-kafka-connector/src/main/resources/kamelets/mariadb-sink.kamelet.yaml +++ b/connectors/camel-mariadb-sink-kafka-connector/src/main/resources/kamelets/mariadb-sink.kamelet.yaml @@ -94,6 +94,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-mariadb-sink + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -108,6 +112,6 @@ spec: json: library: Jackson - to: - uri: "sql:{{query}}" + uri: "{{local-sql-mariadb-sink}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" \ No newline at end of file diff --git a/connectors/camel-mariadb-source-kafka-connector/src/main/resources/kamelets/mariadb-source.kamelet.yaml b/connectors/camel-mariadb-source-kafka-connector/src/main/resources/kamelets/mariadb-source.kamelet.yaml index 0257278580..8dd1b41a32 100644 --- a/connectors/camel-mariadb-source-kafka-connector/src/main/resources/kamelets/mariadb-source.kamelet.yaml +++ b/connectors/camel-mariadb-source-kafka-connector/src/main/resources/kamelets/mariadb-source.kamelet.yaml @@ -96,6 +96,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-mariadb-source + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -104,7 +108,7 @@ spec: url: 'jdbc:mariadb://{{serverName}}:{{serverPort}}/{{databaseName}}' driverClassName: 'org.mariadb.jdbc.Driver' from: - uri: "sql:{{query}}" + uri: "{{local-sql-mariadb-source}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" onConsume: "{{?consumedQuery}}" diff --git a/connectors/camel-mysql-sink-kafka-connector/src/main/resources/kamelets/mysql-sink.kamelet.yaml b/connectors/camel-mysql-sink-kafka-connector/src/main/resources/kamelets/mysql-sink.kamelet.yaml index ee2c68c7bc..1a7b73ba69 100644 --- a/connectors/camel-mysql-sink-kafka-connector/src/main/resources/kamelets/mysql-sink.kamelet.yaml +++ b/connectors/camel-mysql-sink-kafka-connector/src/main/resources/kamelets/mysql-sink.kamelet.yaml @@ -94,6 +94,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-mysql-sink + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -108,6 +112,6 @@ spec: json: library: Jackson - to: - uri: "sql:{{query}}" + uri: "{{local-sql-mysql-sink}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" \ No newline at end of file diff --git a/connectors/camel-mysql-source-kafka-connector/src/main/resources/kamelets/mysql-source.kamelet.yaml b/connectors/camel-mysql-source-kafka-connector/src/main/resources/kamelets/mysql-source.kamelet.yaml index 70580863ea..20d23ad058 100644 --- a/connectors/camel-mysql-source-kafka-connector/src/main/resources/kamelets/mysql-source.kamelet.yaml +++ b/connectors/camel-mysql-source-kafka-connector/src/main/resources/kamelets/mysql-source.kamelet.yaml @@ -96,6 +96,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-mysql-source + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -104,7 +108,7 @@ spec: url: 'jdbc:mysql://{{serverName}}:{{serverPort}}/{{databaseName}}' driverClassName: 'com.mysql.cj.jdbc.Driver' from: - uri: "sql:{{query}}" + uri: "{{local-sql-mysql-source}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" onConsume: "{{?consumedQuery}}" 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 c4b5818a3e..10e9cdd60f 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 @@ -163,7 +163,7 @@ }, "camel.sink.endpoint.producerPoolMaxTotal": { "name": "camel.sink.endpoint.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" @@ -509,7 +509,7 @@ }, "camel.component.netty-http.producerPoolMaxTotal": { "name": "camel.component.netty-http.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" 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 6bf5bd78bf..68664fb8d3 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 @@ -93,7 +93,7 @@ public class CamelNettyhttpSinkConnectorConfig public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_IDLE_DOC = "Sets the cap on the number of idle instances in the pool."; public static final Integer CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_IDLE_DEFAULT = 100; public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_CONF = "camel.sink.endpoint.producerPoolMaxTotal"; - public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit."; + public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang."; public static final Integer CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_DEFAULT = -1; public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_WAIT_CONF = "camel.sink.endpoint.producerPoolMaxWait"; public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MAX_WAIT_DOC = "Sets the maximum duration (value in millis) the borrowObject() method should block before throwing an exception when the pool is exhausted and producerPoolBlockWhenExhausted is true. When less than 0, the borrowObject() method may block indefinitely."; @@ -252,7 +252,7 @@ public class CamelNettyhttpSinkConnectorConfig public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_IDLE_DOC = "Sets the cap on the number of idle instances in the pool."; public static final Integer CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_IDLE_DEFAULT = 100; public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_TOTAL_CONF = "camel.component.netty-http.producerPoolMaxTotal"; - public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit."; + public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang."; public static final Integer CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_TOTAL_DEFAULT = -1; public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_WAIT_CONF = "camel.component.netty-http.producerPoolMaxWait"; public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MAX_WAIT_DOC = "Sets the maximum duration (value in millis) the borrowObject() method should block before throwing an exception when the pool is exhausted and producerPoolBlockWhenExhausted is true. When less than 0, the borrowObject() method may block indefinitely."; 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 187e38e90e..d3647ae2da 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 @@ -135,7 +135,7 @@ }, "camel.sink.endpoint.producerPoolMaxTotal": { "name": "camel.sink.endpoint.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" @@ -508,7 +508,7 @@ }, "camel.component.netty.producerPoolMaxTotal": { "name": "camel.component.netty.producerPoolMaxTotal", - "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.", + "description": "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang.", "defaultValue": "-1", "priority": "MEDIUM", "required": "false" 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 d85666eb82..9f6a301ca8 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 @@ -79,7 +79,7 @@ public class CamelNettySinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_IDLE_DOC = "Sets the cap on the number of idle instances in the pool."; public static final Integer CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_IDLE_DEFAULT = 100; public static final String CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_CONF = "camel.sink.endpoint.producerPoolMaxTotal"; - public static final String CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit."; + public static final String CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang."; public static final Integer CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_TOTAL_DEFAULT = -1; public static final String CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_WAIT_CONF = "camel.sink.endpoint.producerPoolMaxWait"; public static final String CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MAX_WAIT_DOC = "Sets the maximum duration (value in millis) the borrowObject() method should block before throwing an exception when the pool is exhausted and producerPoolBlockWhenExhausted is true. When less than 0, the borrowObject() method may block indefinitely."; @@ -247,7 +247,7 @@ public class CamelNettySinkConnectorConfig extends CamelSinkConnectorConfig { public static final String CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_IDLE_DOC = "Sets the cap on the number of idle instances in the pool."; public static final Integer CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_IDLE_DEFAULT = 100; public static final String CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_TOTAL_CONF = "camel.component.netty.producerPoolMaxTotal"; - public static final String CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit."; + public static final String CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_TOTAL_DOC = "Sets the cap on the number of objects that can be allocated by the pool (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit. Be careful to not set this value too low (such as 1) as the pool must have space to create a producer such as when performing retries. Be mindful that the option producerPoolBlockWhenExhausted is default true, and the pool will then block when there is no space, which can lead to the application to hang."; public static final Integer CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_TOTAL_DEFAULT = -1; public static final String CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_WAIT_CONF = "camel.component.netty.producerPoolMaxWait"; public static final String CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MAX_WAIT_DOC = "Sets the maximum duration (value in millis) the borrowObject() method should block before throwing an exception when the pool is exhausted and producerPoolBlockWhenExhausted is true. When less than 0, the borrowObject() method may block indefinitely."; diff --git a/connectors/camel-oracle-database-sink-kafka-connector/src/main/resources/kamelets/oracle-database-sink.kamelet.yaml b/connectors/camel-oracle-database-sink-kafka-connector/src/main/resources/kamelets/oracle-database-sink.kamelet.yaml index a5004b7134..7518e2b5ec 100644 --- a/connectors/camel-oracle-database-sink-kafka-connector/src/main/resources/kamelets/oracle-database-sink.kamelet.yaml +++ b/connectors/camel-oracle-database-sink-kafka-connector/src/main/resources/kamelets/oracle-database-sink.kamelet.yaml @@ -94,6 +94,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-oracle-sink + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -108,6 +112,6 @@ spec: json: library: Jackson - to: - uri: "sql:{{query}}" + uri: "{{local-sql-oracle-sink}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" \ No newline at end of file diff --git a/connectors/camel-oracle-database-source-kafka-connector/src/main/resources/kamelets/oracle-database-source.kamelet.yaml b/connectors/camel-oracle-database-source-kafka-connector/src/main/resources/kamelets/oracle-database-source.kamelet.yaml index abd93f4cde..72746bf476 100644 --- a/connectors/camel-oracle-database-source-kafka-connector/src/main/resources/kamelets/oracle-database-source.kamelet.yaml +++ b/connectors/camel-oracle-database-source-kafka-connector/src/main/resources/kamelets/oracle-database-source.kamelet.yaml @@ -91,6 +91,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-oracle-source + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -99,7 +103,7 @@ spec: url: 'jdbc:oracle:thin:@{{serverName}}:{{serverPort}}/{{databaseName}}' driverClassName: 'oracle.jdbc.driver.OracleDriver' from: - uri: "sql:{{query}}" + uri: "{{local-sql-oracle-source}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" onConsume: "{{?consumedQuery}}" diff --git a/connectors/camel-postgresql-sink-kafka-connector/src/main/resources/kamelets/postgresql-sink.kamelet.yaml b/connectors/camel-postgresql-sink-kafka-connector/src/main/resources/kamelets/postgresql-sink.kamelet.yaml index 0d3affeb93..6f8878be97 100644 --- a/connectors/camel-postgresql-sink-kafka-connector/src/main/resources/kamelets/postgresql-sink.kamelet.yaml +++ b/connectors/camel-postgresql-sink-kafka-connector/src/main/resources/kamelets/postgresql-sink.kamelet.yaml @@ -91,6 +91,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-postgres-sink + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -105,6 +109,6 @@ spec: json: library: Jackson - to: - uri: "sql:{{query}}" + uri: "{{local-sql-postgres-sink}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" \ No newline at end of file diff --git a/connectors/camel-postgresql-source-kafka-connector/src/main/resources/kamelets/postgresql-source.kamelet.yaml b/connectors/camel-postgresql-source-kafka-connector/src/main/resources/kamelets/postgresql-source.kamelet.yaml index 28d719af4b..8383acf576 100644 --- a/connectors/camel-postgresql-source-kafka-connector/src/main/resources/kamelets/postgresql-source.kamelet.yaml +++ b/connectors/camel-postgresql-source-kafka-connector/src/main/resources/kamelets/postgresql-source.kamelet.yaml @@ -93,6 +93,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-postgres-source + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -101,7 +105,7 @@ spec: url: 'jdbc:postgresql://{{serverName}}:{{serverPort}}/{{databaseName}}' driverClassName: 'org.postgresql.Driver' from: - uri: "sql:{{query}}" + uri: "{{local-sql-postgres-source}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" onConsume: "{{?consumedQuery}}" diff --git a/connectors/camel-snowflake-sink-kafka-connector/src/main/resources/kamelets/snowflake-sink.kamelet.yaml b/connectors/camel-snowflake-sink-kafka-connector/src/main/resources/kamelets/snowflake-sink.kamelet.yaml index 6426e6a51e..ad6b388136 100644 --- a/connectors/camel-snowflake-sink-kafka-connector/src/main/resources/kamelets/snowflake-sink.kamelet.yaml +++ b/connectors/camel-snowflake-sink-kafka-connector/src/main/resources/kamelets/snowflake-sink.kamelet.yaml @@ -85,6 +85,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-snowflake-sink + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:net.snowflake.client.jdbc.SnowflakeBasicDataSource" properties: @@ -99,6 +103,6 @@ spec: json: library: Jackson - to: - uri: "sql:{{query}}" + uri: "{{local-sql-snowflake-sink}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" \ No newline at end of file diff --git a/connectors/camel-snowflake-source-kafka-connector/src/main/resources/kamelets/snowflake-source.kamelet.yaml b/connectors/camel-snowflake-source-kafka-connector/src/main/resources/kamelets/snowflake-source.kamelet.yaml index 863d2a05bb..28e9de2e35 100644 --- a/connectors/camel-snowflake-source-kafka-connector/src/main/resources/kamelets/snowflake-source.kamelet.yaml +++ b/connectors/camel-snowflake-source-kafka-connector/src/main/resources/kamelets/snowflake-source.kamelet.yaml @@ -87,6 +87,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sql-snowflake-source + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:net.snowflake.client.jdbc.SnowflakeBasicDataSource" properties: @@ -95,7 +99,7 @@ spec: url: 'jdbc:snowflake://{{instanceUrl}}' databaseName: '{{?databaseName}}' from: - uri: "sql:{{query}}" + uri: "{{local-sql-snowflake-source}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" onConsume: "{{?consumedQuery}}" diff --git a/connectors/camel-sqlserver-sink-kafka-connector/src/main/resources/kamelets/sqlserver-sink.kamelet.yaml b/connectors/camel-sqlserver-sink-kafka-connector/src/main/resources/kamelets/sqlserver-sink.kamelet.yaml index 4c999c36fe..782b6baae8 100644 --- a/connectors/camel-sqlserver-sink-kafka-connector/src/main/resources/kamelets/sqlserver-sink.kamelet.yaml +++ b/connectors/camel-sqlserver-sink-kafka-connector/src/main/resources/kamelets/sqlserver-sink.kamelet.yaml @@ -104,6 +104,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sqlserver-sink + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -118,6 +122,6 @@ spec: json: library: Jackson - to: - uri: "sql:{{query}}" + uri: "{{local-sqlserver-sink}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" \ No newline at end of file diff --git a/connectors/camel-sqlserver-source-kafka-connector/src/main/resources/kamelets/sqlserver-source.kamelet.yaml b/connectors/camel-sqlserver-source-kafka-connector/src/main/resources/kamelets/sqlserver-source.kamelet.yaml index a007c2f654..e32df74a88 100644 --- a/connectors/camel-sqlserver-source-kafka-connector/src/main/resources/kamelets/sqlserver-source.kamelet.yaml +++ b/connectors/camel-sqlserver-source-kafka-connector/src/main/resources/kamelets/sqlserver-source.kamelet.yaml @@ -106,6 +106,10 @@ spec: - "mvn:org.apache.commons:commons-dbcp2:2.12.0" template: beans: + - name: local-sqlserver-source + type: "#class:org.apache.camel.component.sql.SqlComponent" + properties: + autowiredEnabled: "false" - name: dsBean type: "#class:org.apache.commons.dbcp2.BasicDataSource" properties: @@ -114,7 +118,7 @@ spec: url: 'jdbc:sqlserver://{{serverName}}:{{serverPort}};databaseName={{databaseName}};encrypt={{encrypt}};trustServerCertificate={{trustServerCertificate}};' driverClassName: 'com.microsoft.sqlserver.jdbc.SQLServerDriver' from: - uri: "sql:{{query}}" + uri: "{{local-sqlserver-source}}:{{query}}" parameters: dataSource: "#bean:{{dsBean}}" onConsume: "{{?consumedQuery}}"