You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by liuxiangcao <xi...@gmail.com> on 2022/10/04 20:15:38 UTC

Support avro-confluent format for FileSystem SQL connector

Hi Flink community,

According to flink doc, avro-confluent([1]) is only supported for kafka sql
connector and upsert kafka sql connector.

I'm wondering if there is any reason this format is not supported for
Filesystem sql connector ([2])  ?

We are looking to use FileSystem sink to write to s3 in avro format and
would like to keep the sink to be in sync with avro schema registry. Is
there any gotchas that we should be aware in implementing avro-confluent
format for file system sink?

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/formats/avro-confluent/
[2]
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/filesystem/

-- 
Best Wishes & Regards
Shawn Xiangcao Liu