Since Kafka allows dot character in topic names (for example my.test.topic) we use them as word separator. Unfortunately, connector attached to the topic with this name will try to create Scylla table dottest.my.test.topic and throw following exception:
...
[2020-05-19 11:27:14,248] INFO create() - Adding table dottest.my.test.topic
CREATE TABLE dottest.my.test.topic(
id int,
firstName varchar,
lastName varchar,
PRIMARY KEY(id))
WITH compression = {'sstable_compression' : ''} (io.connect.scylladb.ScyllaDbSchemaBuilder:341)
[2020-05-19 11:27:14,269] ERROR WorkerSinkTask{id=scylladb-sink-connector-dot-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: line 2:24 : syntax error...
(org.apache.kafka.connect.runtime.WorkerSinkTask:566)
...
Environment:
mvn clean install of coomit aa89618ccbab7aa2d14da67c7b86a305dd1e914d
local confluent v5.5.0
local scyllaDB cluster
connector definition
Since Kafka allows dot character in topic names (for example
my.test.topic
) we use them as word separator. Unfortunately, connector attached to the topic with this name will try to create Scylla tabledottest.my.test.topic
and throw following exception:Environment:
mvn clean install
of coomitaa89618ccbab7aa2d14da67c7b86a305dd1e914d
local confluent v5.5.0 local scyllaDB cluster connector definition