Skip to content

Instantly share code, notes, and snippets.

@andrewstevenson

andrewstevenson/start-cassandra-sink.sh

Created September 8, 2016 18:22
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save andrewstevenson/dfd8e52decf6b22e04be82efeea18a32 to your computer and use it in GitHub Desktop.
Save andrewstevenson/dfd8e52decf6b22e04be82efeea18a32 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
start-cassandra-sink.sh
java -jar kafka-connect-cli-0.5-all.jar create cassandra-sink-orders < cassandra-sink-distributed-orders.properties
#Connector `cassandra-sink-orders`:
name=cassandra-sink-orders
connector.class=com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector
tasks.max=1
topics=orders-topic
connect.cassandra.export.route.query=INSERT INTO orders SELECT * FROM orders-topic
connect.cassandra.contact.points=localhost
connect.cassandra.port=9042
connect.cassandra.key.space=demo
connect.cassandra.contact.points=localhost
connect.cassandra.username=cassandra
connect.cassandra.password=cassandra
#task ids: 0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment