Поддерживает ли приемник Cont Sink VoltDB сообщения Avro? - PullRequest
Новая
       9

Поддерживает ли приемник Cont Sink VoltDB сообщения Avro?

0 голосов
/ 02 октября 2018

Поддерживает ли соединитель VoltDB Kafka чтение авро-сообщений? Ниже приведена моя попытка настроить соединитель? 

{
   "name":"KafkaSinkConnector",
   "config":{
      "connector.class":"org.voltdb.connect.kafka.KafkaSinkConnector",
      "tasks.max":"1",
      "voltdb.servers":"node1:21212,node2:21212,node3:21212",
      "voltdb.procedure":"USER.insert",
      "voltdb.connection.user":"test",
      "voltdb.connection.password":"test",
      "topics":"user",
      "key.converter":"io.confluent.connect.avro.AvroConverter",
      "key.converter.schema.registry.url":"http://kafka-schema-registry:8081",
      "value.converter":"io.confluent.connect.avro.AvroConverter",
      "value.converter.schema.registry.url":"http://kafka-schema-registry:8081",
      "key.converter.schemas.enable":"true",
      "value.converter.schemas.enable":"true", 
   }
}

Загружается соединитель без сообщений об ошибках, но в БД ничего не записывается.

1 Ответ

0 голосов
/ 02 октября 2018

К сожалению, ни импортер Kafka, ни соединитель приемника в настоящее время не поддерживают сообщения Avro.Тем не менее, это хороший запрос, который можно добавить в будущем.

Полное раскрытие: я работаю на VoltDB.

-Andrew

...