[GitHub] [camel-kafka-connector-examples] nathanhagemann edited a comment on issue #336: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets

[GitBox]

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: 
           FIRST COLUMN: type     SECOND COLUMN: invented
   0    FIRST COLUMN: {"Type:":"Pecan","Invented":1870} SECOND COLUMN: NaN
   
   
   


-- 
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-unsubscr...@camel.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org