Как десериализовать перечисление Avro в языке SQL Flink?

#apache-kafka #apache-flink #avro #flink-sql Вопрос: У меня есть тема Кафки со следующим Avro IDL и зарегистрирована в реестре схем. @namespace("my.type.avro") protocol MyProtocol { enum MyEnumType { Type1, Type2 } record…

Продолжить чтениеКак десериализовать перечисление Avro в языке SQL Flink?