Hi Everyone:
   I used protobuf in kafka,in java code ,I could define custom 
Deserializer,but how colud I do this on pyflink?

Reply via email to