Is it possible to customize avro schema name when using SQL

[tao xiao]

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? 

--

[Nicolaus Weidner]

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 <[hidden email]> 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