Add configurable consistency level and local DC

scylladb / scylla-cdc-source-connector

A Kafka source connector capturing Scylla CDC changes

Apache License 2.0

46 stars 18 forks source link

Add configurable consistency level and local DC #5

Closed avelanarius closed 3 years ago

avelanarius commented 3 years ago

Add a configurable consistency level and local DC parameters. By default, consistency level is QUORUM and there is no local DC set.

Tested on a local 5 node Scylla cluster (2 nodes in dc1, 3 nodes in dc2) - both whether consistency level was correctly set and if correct local DC was used.

Fixes #3.