Re: Apache flink doesn't work with avro kafka topic with multiple event types

2022-06-13 Thread Sucheth S
Thanks, I'll check it out. On Mon, Jun 13, 2022 at 2:40 AM Qingsheng Ren wrote: > Hi Sucheth, > > If you are referring to Table / SQL API, I'm afraid it doesn't support > schema evolution or different types from one Kafka table. An > alternative way is to consume the topic with raw format [1] an

Fwd: Apache flink doesn't work with avro kafka topic with multiple event types

2022-06-13 Thread Qingsheng Ren
Hi Sucheth, If you are referring to Table / SQL API, I'm afraid it doesn't support schema evolution or different types from one Kafka table. An alternative way is to consume the topic with raw format [1] and do deserialization with a UDTF. If you are using the DataStream API, you can implement the

Apache flink doesn't work with avro kafka topic with multiple event types

2022-06-11 Thread Sucheth S
Hi, Apache Flink doesn't work with Avro serialized kafka topic with multiple event types ( TopicRecordNameStrategy for subject ) Is there a way to read a generic record from avro serialized kafka topic which can have messages with different schemas, basically TopicRecordNameStrategy for the subje