时间戳

首页 > 解决方案 > VoltDB 的连接器接收器是否支持 Avro 消息？

apache-kafka-connect - VoltDB 的连接器接收器是否支持 Avro 消息？

问题描述

VoltDB 的 Kafka 连接器是否支持读取 avro 消息 下面是我配置连接器的尝试吗？

{
   "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", 
   }
}

显示没有错误消息的连接器加载，但没有任何内容写入数据库。

标签： apache-kafka-connectvoltdb

解决方案

不幸的是，Kafka 导入器和接收器连接器目前都不支持 Avro 消息。但是，这是一个很好的功能请求，将来可能会添加。

全面披露：我为 VoltDB 工作。

-安德鲁

推荐阅读