Scylla is protocol compatible with Cassandra, so you can just use the Cassandra connector. Scylla has extended the Go gocql package to make it shard aware, but such an extension does not exist for the Cassandra Java driver. That just means that the driver will sent requests to any shard on a node, rather than to the specific shard that will process the request, resulting in slightly higher load.
On Sun, Aug 11, 2019 at 11:06 PM Lian Jiang <jiangok2...@gmail.com> wrote: > Hi, > > i am new to Flink. Is there scylla connector equivalent to the cassandra > connector: > https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/connectors/cassandra.html? > Or can Flink use Scylla as a sink via the cassandra connector? Thanks. >
