Thanks, I'll check it out. On Mon, Jun 13, 2022 at 2:40 AM Qingsheng Ren <renqs...@gmail.com> 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] and do > deserialization with a UDTF. If you are using the DataStream API, you > can implement the KafkaRecordDeserializationSchema interface to > deserialize the message consumed from Kafka. > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/formats/raw/ > > Best regards, > > Qingsheng > > On Sun, Jun 12, 2022 at 12:53 PM Sucheth S <suchet...@gmail.com> wrote: > > > > 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 subject in the schema registry. ? > > > > > > Regards, > > Sucheth Shivakumar > > website : https://sucheths.com > > mobile : +1(650)-576-8050 > > San Mateo, United States > -- Regards, Sucheth Shivakumar website: https://sucheths.com Mobile : +1(650)-576-8050 San Mateo, United States
