我有一个 Flink 消费者，它使用一个 protobuf 结构，只需要几个字段就可以发送给其他运营商。目前，我正在使用一个简单的自定义 deser 模式，它只返回 pb，然后是一个平面图函数来过滤掉字段。
我正在考虑的一种方法是更改 deser 类以创建并返回一个只填充了那些字段的新 pb，但这似乎不是一个优雅的解决方案，所以我想知道是否有更好的方法。