It still doesn't support custom Deserializer developed with Python language. However, you could create a Java Deserializer and use it in PyFlink.
Regards, Dian On Thu, Jun 2, 2022 at 10:25 AM [email protected] < [email protected]> wrote: > > Hi Everyone: > I used protobuf in kafka,in java code ,I could define > custom Deserializer,but how colud I do this on pyflink? > >
