Re: Handling default fields in Avro messages using Flink SQL

2023-11-13 Thread Hang Ruan
Hi, Dale. I think there are two choices to try. 1. As the reply in #22427[1], use the SQL function `COALESCE`. 2. Modify the code in Avro format by yourself. There is some work to do for the choice 2. First, you need to pass the default value in Schema, which does not contain the default value

Handling default fields in Avro messages using Flink SQL

2023-11-13 Thread Dale Lane
I have a Kafka topic with events produced using an Avro schema like this: { "namespace": "demo.avro", "type": "record", "name": "MySimplifiedRecreate", "fields": [ { "name": "favouritePhrase", "type": "string", "default": "Hello World"