You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/21 12:40:39 UTC
[camel-kafka-connector] 02/02: itest-cassandra: add workaround for
CAMEL-15722
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 0801cd41ca213a122c6fa24b270a6ed552d7e250
Author: Luca Burgazzoli <lb...@gmail.com>
AuthorDate: Wed Oct 21 11:28:31 2020 +0200
itest-cassandra: add workaround for CAMEL-15722
---
.../kafkaconnector/cassandra/sink/CamelCassandraPropertyFactory.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelCassandraPropertyFactory.java b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelCassandraPropertyFactory.java
index 1222010..6f8e598 100644
--- a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelCassandraPropertyFactory.java
+++ b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelCassandraPropertyFactory.java
@@ -30,7 +30,9 @@ final class CamelCassandraPropertyFactory extends SinkConnectorPropertyFactory<C
}
public CamelCassandraPropertyFactory withCql(String cql) {
- return setProperty("camel.sink.endpoint.cql", cql);
+ // RAW is required as the endpoint URI builder encodes the URI
+ // TODO: remove once https://issues.apache.org/jira/browse/CAMEL-15722 get fixed
+ return setProperty("camel.sink.endpoint.cql", "RAW(" + cql + ")");
}
public CamelCassandraPropertyFactory withHosts(String hosts) {