Hi Tao,
This is currently not possible using Table API, though this will likely
change in a future version. Currently, you would have to do that using the
Datastream API [1] and then switch to the Table API.
Best wishes,
Nico
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/
On Sun, Jun 6, 2021 at 9:55 AM tao xiao wrote:
> Hi team,
>
> I want to use avro-confluent to encode the data using SQL but the schema
> registered by the encoder hard code the schema name to 'record'. is it
> possible to dictate the name?
>
> --
> Regards,
> Tao
>
