Соединитель раковины Cassandra для платформы Confluent - PullRequest
Новая
       55

Соединитель раковины Cassandra для платформы Confluent

0 голосов
/ 29 мая 2020

Я пытаюсь запустить коннектор раковины Cassandra для сливной платформы. Файл cassandra-раковина. json выглядит следующим образом: 

 {
      "name" : "cassandra-sink",
      "config" : {
        "connector.class" : "io.confluent.connect.cassandra.CassandraSinkConnector",
        "tasks.max" : "1",
        "topics" : "topic1",
        "cassandra.contact.points" : "127.0.0.1",
        "cassandra.keyspace" : "test",
        "confluent.topic.bootstrap.servers": "127.0.0.1:9092",
        "cassandra.write.mode" : "Update",
        "connect.cassandra.port":"127.0.0.1:9042"

      }
    }

Я скачал confluent-hub install confluentinc/kafka-connect-cassandra:latest по ссылке 1006 *.

Я могу загрузить файл, но когда я проверяю статус, я получаю следующую ошибку. Я не могу понять, в чем проблема. 

FAILED worker_id:127.0.0.1:8083,trace:com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed 
com.datastax.driver.core.exceptions.TransportException: [/127.0.0.1:9042] Cannot connect
com.datastax.driver.core.ControlConnection.reconnectInternal
com.datastax.driver.core.ControlConnection.connect
com.datastax.driver.core.Cluster$Manager.negotiateProtocolVersionAndConnect
com.datastax.driver.core.Cluster$Manager.init
com.datastax.driver.core.Cluster.init
com.datastax.driver.core.SessionManager.initAsync
com.datastax.driver.core.SessionManager.executeAsync
com.datastax.driver.core.AbstractSession.execute
io.confluent.connect.cassandra.CassandraSessionImpl.executeStatement
io.confluent.connect.cassandra.CassandraSinkConnector.doStart
io.confluent.connect.cassandra.CassandraSinkConnector.start
org.apache.kafka.connect.runtime.WorkerConnector.doStart
org.apache.kafka.connect.runtime.WorkerConnector.start
org.apache.kafka.connect.runtime.WorkerConnector.transitionTo 
org.apache.kafka.connect.runtime.Worker.startConnector
org.apache.kafka.connect.runtime.distributed.DistributedHerder.startConnector 
org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1300
org.apache.kafka.connect.runtime.distributed.DistributedHerder$14
org.apache.kafka.connect.runtime.distributed.DistributedHerder$14 
java.util.concurrent.FutureTask.run java.util.concurrent.ThreadPoolExecutor.runWorker
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
             java.lang.Thread.run

Пожалуйста, укажите.

...