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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
