You need to enable JavaScript to run this app.
导航
Flink 支持 protobuf 格式
最近更新时间:2025.03.11 19:33:29首次发布时间:2025.03.11 19:33:29
我的收藏
有用
有用
无用
无用

Flink 1.16 已支持Protobuf格式[1],但默认情况下并没有将相关的适配逻辑放在其发布包中。因此,当用户希望使用flink原生支持Protobuf格式的特性,需要从Maven仓库自行下载特定的依赖。以火山引擎EMR Flink 1.16.1版本为例,用户可以下载对应版本的依赖包[2],将jar依赖包放到EMR master节点的Flink发布包中lib目录下。如果用户不想变更flink发布包,也可以在Job粒度引入依赖,在自己的Flink job项目源码的pom.xml中,加入如下依赖:

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-protobuf</artifactId>
    <version>1.16.1</version>
</dependency>

这样用户就可以在Flink SQL中正常处理Protobuf格式的数据了。相关的demo和配置可参考官网文档[3]