Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #Connector `cassandra-sink`:
- name=cassandra-sink
- connector.class=com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector
- tasks.max=1
- topics=temperature
- connect.cassandra.kcql=INSERT INTO temperature SELECT * FROM temperature
- connect.cassandra.contact.points=<IP1>,<IP2> (public IP addresses SCYLLA nodes)
- connect.cassandra.port=9042
- connect.cassandra.key.space=demo
- connect.cassandra.username=cassandra
- connect.cassandra.password=cassandra
- connect.progress.enabled=true
- #task ids: 0
Add Comment
Please, Sign In to add comment