Hi Everyone: I used protobuf in kafka,in java code ,I could define custom Deserializer,but how colud I do this on pyflink?
- How to parse protobuf data from kafka by pyfl... [email protected]
Hi Everyone: I used protobuf in kafka,in java code ,I could define custom Deserializer,but how colud I do this on pyflink?