You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by "laizhichun@hongkingsystem.cn" <la...@hongkingsystem.cn> on 2022/06/02 02:18:35 UTC

How to parse protobuf data from kafka by pyflink

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