Hello, I’m having the following error. Have you had this error before? If yes, what did you do to fix it?
Create:
{
"name": "cassandra-connection",
"config": {
"connector.class": "io.confluent.connect.cassandra.CassandraSinkConnector",
"tasks.max": "1",
"topics": "Pg.dbo.Transaction",
"cassandra.contact.points": "cassandra",
"cassandra.keyspace": "pg",
"cassandra.keyspace.create.enabled": "true",
"cassandra.table.manage.enabled": "true",
"cassandra.write.mode": "Insert",
"cassandra.local.datacenter": "datacenter1",
"confluent.topic.bootstrap.servers": "host.docker.internal:9092"
}
}
Status:
{
"name": "cassandra-connection",
"connector": {
"state": "RUNNING",
"worker_id": "172.17.0.6:8083"
},
"tasks": [
{
"id": 0,
"state": "FAILED",
"worker_id": "172.17.0.6:8083",
"trace": "org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:611)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:333)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:234)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:203)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:188)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:243)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:829)\nCaused by: java.lang.IllegalArgumentException: Invalid CQL form [Pg.dbo.Transaction]: needs double quotes\n\tat com.datastax.oss.driver.shaded.guava.common.base.Preconditions.checkArgument(Preconditions.java:216)\n\tat com.datastax.oss.driver.api.core.CqlIdentifier.fromCql(CqlIdentifier.java:79)\n\tat com.datastax.oss.driver.api.core.metadata.schema.KeyspaceMetadata.getTable(KeyspaceMetadata.java:56)\n\tat io.confluent.connect.cassandra.CassandraSessionImpl.tableMetadata(CassandraSessionImpl.java:83)\n\tat io.confluent.connect.cassandra.ConnectSchemaBuilder.build(ConnectSchemaBuilder.java:223)\n\tat io.confluent.connect.cassandra.CassandraSessionImpl.ensureTable(CassandraSessionImpl.java:100)\n\tat io.confluent.connect.cassandra.CassandraSinkTask.put(CassandraSinkTask.java:118)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581)\n\t... 10 more\n"
}
],
"type": "sink"
}