CREATETABLEuser_behavior(user_idBIGINT,item_idBIGINT,category_idBIGINT,behaviorSTRING,tsTIMESTAMP(3))WITH('connector'='kafka','properties.bootstrap.servers'='localhost:9092','topic'='user_behavior','format'='avro-confluent','avro-confluent.schema-registry.url'='http://localhost:8081','avro-confluent.schema-registry.subject'='user_behavior')
如上所示，我并不是想要知道如何在flink sql中连接confluent schema registry，而是想要通过catalog获取schema
registry上对应topic的schema信息，以便我不需要手动输入那些fields字段，如同JdbcCatalog那样，直接使用已有表一样，我想直接使用topic，而不需要定义DDL
在 2020-12-15 00:34:03，"guoliubi...@foxmail.com" <guoliubi...@foxmail.com> 写道：
>Confluent Schema Registry参考这个
>https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/formats/avro-confluent.html
>
>
>
>
>guoliubi...@foxmail.com
>
>发件人： 陈帅
>发送时间： 2020-12-14 23:33
>收件人： user-zh@flink.apache.org
>主题： 如何让FlinkSQL访问到阿里云MaxCompute上的表？
>如何让FlinkSQL访问到阿里云MaxCompute上的表？
>又或者是Confluent Schema Registry上那些带schema的kafka topic?
>需要自己定义Catalog吗？有相关的教程和资料么？谢谢！
