Hi, I am looking at the DataStream connectors and I saw there is an avro connector, unfortunatly I am using Confluent Avro Schemas. Am I forced to use table API to fetch/write the data? I already have POJOs and Schemas for all the models and I was hoping I could just pass the POJO to DataStream instead of having to define the table for each pojo in table API

Hey. Look into

ConfluentAvroDeserializationSchema.forSpecific

- https://nightlies.apache.org/flink/flink-docs-master/api/java/

Yes I did thanks for your help

I think I need your help. I was using the

forGeneric

method earlier but I want to use

forSpecific

instead but I keep getting a POJO type info error. Here is the original question, do you know what might help. https://apache-flink.slack.com/archives/C03G7LJTS2G/p1675194120953569

The “POJO” has to implement SpecificRecord, in my brief experience.