An Apache Kafka® sink for transferring events/messages from Kafka topics to Apache Cassandra®, DataStax Astra or DataStax Enterprise (DSE).
To download and install this connector please follow the procedure detailed here.
All documentation is available online here.
If you want to develop and test the connector you need to build the jar from sources. To do so please follow those steps:
First build the uber-jar:
mvn clean package
Open the Connect worker config file
config/connect-standalone.properties. Update the plugin
search path to include the uber-jar:
dist/conf/cassandra-sink-standalone.properties.sampleconfig file in this project to meet your needs, or copy it out and edit elsewhere. The edited file should be named
Run connect-standalone and specify the path to the that config file:
In Confluent, you would do this:
bin/confluent load cassandra-sink -d
To see practical examples and usages of mapping, see: https://docs.datastax.com/en/kafka/doc/search.html?searchQuery=mapping
© 2020 Anant Corporation, All Rights Reserved. All logos, trademarks and registered trademarks are the property of their respective owners. .