flink sql confluent schema avro topic注册成表

目前社区确实不支持confluent schema registry的avro格式，我们内部也是依赖schema registry来做avro

schema的管理，所以，我们改动了flink-avro 的源码来支持。

主要涉及到这些地方：

org.apache.flink.formats.avro.{AvroRowFormatFactory,AvroRowDeserializationSchema,AvroRowSerializationSchema}

和org.apache.flink.table.descriptors.{Avro,AvroValidator}

使用时在构建Avro时指定以下三个参数即可（见标红部分）：

tableEnv.connect(

new Kafka()

.version("universal")

.topic(topic)

.properties(props)

).withFormat(

new Avro()

.useRegistry(true)

.registryUrl(KAFKA_SCHEMA_REGISTRY_URL_ADDRESS)

.registrySubject(subject)

.avroSchema(avroSchemaStr)

)

*来自志愿者整理的flink邮件归档