[create-pull-request] automated change

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",

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"

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"

connectors/camel-aws-redshift-sink-kafka-connector/pom.xml

@@ -62,15 +62,15 @@
       <artifactId>commons-dbcp2</artifactId>
       <version>2.12.0</version>
     </dependency>
-    <dependency>
-      <groupId>com.amazon.redshift</groupId>
-      <artifactId>redshift-jdbc42</artifactId>
-      <version>2.1.0.30</version>
-    </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kamelet</artifactId>
     </dependency>
+    <dependency>
+      <groupId>com.amazon.redshift</groupId>
+      <artifactId>redshift-jdbc42</artifactId>
+      <version>2.1.0.31</version>
+    </dependency>
     <!--END OF GENERATED CODE-->
   </dependencies>
   <build>

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}}"

connectors/camel-aws-redshift-source-kafka-connector/pom.xml

@@ -62,15 +62,15 @@
       <artifactId>commons-dbcp2</artifactId>
       <version>2.12.0</version>
     </dependency>
-    <dependency>
-      <groupId>com.amazon.redshift</groupId>
-      <artifactId>redshift-jdbc42</artifactId>
-      <version>2.1.0.30</version>
-    </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kamelet</artifactId>
     </dependency>
+    <dependency>
+      <groupId>com.amazon.redshift</groupId>
+      <artifactId>redshift-jdbc42</artifactId>
+      <version>2.1.0.31</version>
+    </dependency>
     <!--END OF GENERATED CODE-->
   </dependencies>
   <build>

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}}"

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}}"

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}}"

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",

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);

connectors/camel-jms-apache-artemis-sink-kafka-connector/pom.xml

@@ -44,7 +44,7 @@
     <dependency>
       <groupId>org.apache.activemq</groupId>
       <artifactId>artemis-jakarta-client-all</artifactId>
-      <version>2.37.0</version>
+      <version>2.38.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.camel.kafkaconnector</groupId>

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

connectors/camel-jms-apache-artemis-source-kafka-connector/pom.xml

@@ -44,7 +44,7 @@
     <dependency>
       <groupId>org.apache.activemq</groupId>
       <artifactId>artemis-jakarta-client-all</artifactId>
-      <version>2.37.0</version>
+      <version>2.38.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.camel.kafkaconnector</groupId>

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

connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/pom.xml

@@ -49,7 +49,7 @@
     <dependency>
       <groupId>org.apache.activemq</groupId>
       <artifactId>artemis-jakarta-client-all</artifactId>
-      <version>2.37.0</version>
+      <version>2.38.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.camel.kafkaconnector</groupId>

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:

connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/pom.xml

@@ -49,7 +49,7 @@
     <dependency>
       <groupId>org.apache.activemq</groupId>
       <artifactId>artemis-jakarta-client-all</artifactId>
-      <version>2.37.0</version>
+      <version>2.38.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.camel.kafkaconnector</groupId>

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:

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}}"

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}}"

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}}"