Hi, I am experimenting Flink SQL by following https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sqlClient.html. I want to set up an environment yaml to query Kafka data (json in avro format). Where can I find the information below?
1. use GenericInMemoryCatalog (e.g. type, settings) 2. use Kafka schema registry for schema. The example hard code the schema in env yaml. 3. other than UDF, is there a way to easily query a deeply nested json in Flink SQL? Appreciate your help! Regards Lian
