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-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new 6408e0b Fix cassandra kamelets
6408e0b is described below
commit 6408e0b8165827c06c954629f60511231a1caa8a
Author: Andrej Smigala <[email protected]>
AuthorDate: Tue Jan 18 11:02:40 2022 +0100
Fix cassandra kamelets
* fix prepareStatements sink parameter
* change default consistency level for source
---
kamelets/cassandra-sink.kamelet.yaml | 6 +++---
kamelets/cassandra-source.kamelet.yaml | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/kamelets/cassandra-sink.kamelet.yaml
b/kamelets/cassandra-sink.kamelet.yaml
index c35bcf0..06c4d5a 100644
--- a/kamelets/cassandra-sink.kamelet.yaml
+++ b/kamelets/cassandra-sink.kamelet.yaml
@@ -74,8 +74,8 @@ spec:
description: Consistency level to use. The value can be one of ANY,
ONE, TWO, THREE, QUORUM, ALL, LOCAL_QUORUM, EACH_QUORUM, SERIAL, LOCAL_SERIAL,
LOCAL_ONE
type: string
default: ANY
- preparedStatement:
- title: Prepared Statement
+ prepareStatements:
+ title: Prepare Statements
description: Whether to use PreparedStatements or regular Statements
as the query.
type: boolean
default: true
@@ -105,6 +105,6 @@ spec:
parameters:
username: "{{?username}}"
password: "{{?password}}"
- preparedStatement: "{{preparedStatement}}"
+ prepareStatements: "{{prepareStatements}}"
consistencyLevel: "{{consistencyLevel}}"
cql: "{{query}}"
diff --git a/kamelets/cassandra-source.kamelet.yaml
b/kamelets/cassandra-source.kamelet.yaml
index 3f2dba9..1f2f6be 100644
--- a/kamelets/cassandra-source.kamelet.yaml
+++ b/kamelets/cassandra-source.kamelet.yaml
@@ -76,7 +76,7 @@ spec:
title: Consistency Level
description: Consistency level to use. The value can be one of ANY,
ONE, TWO, THREE, QUORUM, ALL, LOCAL_QUORUM, EACH_QUORUM, SERIAL, LOCAL_SERIAL,
LOCAL_ONE
type: string
- default: ANY
+ default: QUORUM
query:
title: Query
description: The query to execute against the Cassandra cluster table
