@I_Mesh01 This error is stating that your topic schema and flink schema do not match. I cant see much above related to the shape of the data or the schema, but this is what you should be looking at. Conflict in data/column types, missing data, etc, will result in the deserialization errors.
... View more
