You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2022/03/19 11:53:30 UTC
[GitHub] [camel-kafka-connector-examples] nathanhagemann edited a comment on issue #336: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
nathanhagemann edited a comment on issue #336:
URL: https://github.com/apache/camel-kafka-connector-examples/issues/336#issuecomment-1072995856
Also tried with CamelCassandraQLSinkConnector
--######################################
name=CamelCassandraQLSinkConnector
topics=pie
tasks.max=1
connector.class=org.apache.camel.kafkaconnector.cql.CamelCqlSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
camel.sink.path.hosts=10.66.16.10
camel.sink.path.port=9042
camel.sink.path.keyspace=dev
camel.sink.endpoint.cql=INSERT INTO pie (type, invented) VALUES (?,?)
camel.sink.endpoint.username=cameldevloader
camel.sink.endpoint.password=newpassword
--######################################
This works but all of the data is in the first field like this:
type\t\t\tinvented
0 {"Type:":"Pecan","Invented":1870}\t\tNaN
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org