Scylla Sink Connector provides the functionality to automatically create Scylla table based on Kafka message schema.
However, the generated CREATE TABLE query does not correctly quote column names (for example if you have a column name one two three with spaces you must write it in quotes "one two three" - quoteIfNecessary method in Java Driver).
Scylla Sink Connector provides the functionality to automatically create Scylla table based on Kafka message schema.
However, the generated
CREATE TABLE
query does not correctly quote column names (for example if you have a column nameone two three
with spaces you must write it in quotes"one two three"
-quoteIfNecessary
method in Java Driver).Reproducer:
CREATE KEYSPACE ks WITH REPLICATION = {'class': 'SimpleStrategy', 'replication_factor': 1};
mytable
topic.primary key
andck!@#$%^&*()
):/tmp/confluent.XXXXXX/connect/logs/connect.log
in case of Confluent) you can see:The correct query should be: