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

Reply via email to