From ac46e4266f2ac1442f5e2024e55e9d2c02024644 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Mon, 25 Nov 2024 17:26:46 +0100 Subject: [PATCH] Cassandra Kamelets: Disable autowiring by default - CQL Sink Signed-off-by: Andrea Cosentino --- kamelets/cassandra-sink.kamelet.yaml | 7 ++++++- .../main/resources/kamelets/cassandra-sink.kamelet.yaml | 7 ++++++- 2 files changed, 12 insertions(+), 2 deletions(-) diff --git a/kamelets/cassandra-sink.kamelet.yaml b/kamelets/cassandra-sink.kamelet.yaml index 39d04cb9e..9e365d73e 100644 --- a/kamelets/cassandra-sink.kamelet.yaml +++ b/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/library/camel-kamelets/src/main/resources/kamelets/cassandra-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/cassandra-sink.kamelet.yaml index 39d04cb9e..9e365d73e 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/cassandra-sink.kamelet.yaml +++ b/library/camel-kamelets/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}}"