Auto-Table поколения в Кассандре с кафкой подключить раковину Кассандра - PullRequest
Новая
       13

Auto-Table поколения в Кассандре с кафкой подключить раковину Кассандра

0 голосов
/ 29 ноября 2018

Я using confluent.connect.cassandra.CassandraSinkConnector, для kafka подключите приемник cassandra.

Я хотел знать, можно ли автоматически генерировать таблицы cassandra из раздела kafka, используя io.confluent.connect.cassandra.CassandraSinkConnector в качестве соединителя.

Если это возможно, подскажите, пожалуйста, какую конфигурацию настроить для включения этой функции.Я перепробовал все конфигурации, упомянутые в документации, но мне не удалось создать таблицу.

Это конфигурация, которую я использую: 

{
  "name": "cassandra-test4",

  "config": {

    "connector.class": "io.confluent.connect.cassandra.CassandraSinkConnector",

    "tasks.max": "3",

    "topics": "orders-topic2",

    "cassandra.contact.points": "my_ip",

    "cassandra.keyspace": "test_cas",

    "cassandra.write.mode": "Insert",

    "cassandra.table.manage.enabled": "true",

    "cassandra.sink.route": "test_cas.orders",

    "key.converter.schema.registry.url": "http://localhost:8081",

    "value.converter.schema.registry.url": "http://localhost:8081",

    "value.converter": "io.confluent.connect.avro.AvroConverter",

    "key.converter": "org.apache.kafka.connect.storage.StringConverter",

    "flush.size": "1",

    "cassandra.keyspace.create.enabled": "true",

    "name": "cassandra-test4"

  },

  "tasks": [

    {

      "connector": "cassandra-test4",

      "task": 0

    },

    {

      "connector": "cassandra-test4",

      "task": 1

    },

    {

      "connector": "cassandra-test4",

      "task": 2

    }

  ],

  "type": null

}

1 Ответ

0 голосов
/ 29 ноября 2018

Это должно быть сделано путем установки cassandra.keyspace.create.enabled & cassandra.table.manage.enabled свойств на true.См. документацию .

Но будьте очень осторожны - очень легко получить несогласие со схемой в вашем кластере, а затем вам нужно выполнить дополнительные шаги для восстановления после нее.Лучше предварительно создавать таблицы перед запуском коннектора ...

...