VoltDB的连接器接收器是否支持Avro消息？

Question

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

连接器加载时不显示任何错误消息，但不会向数据库写入任何内容。

Answer 1

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

完全披露：我在VoltDB工作。

-安德鲁