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-examples.git
The following commit(s) were added to refs/heads/master by this push:
new b6ada46 Fixes CQL Source example
b6ada46 is described below
commit b6ada4698b168a71fc9f2c25e79a1ea237ed0b58
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Jun 30 20:57:23 2020 +0200
Fixes CQL Source example
---
cql/cql-source/config/CamelCassandraQLSourceConnector.properties | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/cql/cql-source/config/CamelCassandraQLSourceConnector.properties
b/cql/cql-source/config/CamelCassandraQLSourceConnector.properties
index 63b3939..c56e032 100644
--- a/cql/cql-source/config/CamelCassandraQLSourceConnector.properties
+++ b/cql/cql-source/config/CamelCassandraQLSourceConnector.properties
@@ -23,7 +23,8 @@
value.converter=org.apache.kafka.connect.storage.StringConverter
topics=mytopic
camel.source.path.hosts=172.17.0.2
-camel.source.path.keyspace=9042/test
+camel.source.path.port=9042
+camel.source.path.keyspace=test
camel.source.endpoint.cql=select * from users
camel.source.endpoint.delay=10000
