文章 2024-04-07 来自:开发者社区

阿里云Flink-自定义kafka format实践及踩坑记录(以protobuf为例)

1. protobuf简介 Protocol Buffers(简称:ProtoBuf)是一种开源跨平台的序列化数据结构的协议。其对于存储资料或在网络上进行通信的程序是很有用的。这个方法包含一个接口描述语言,描述一些数据结构,并提供程序工具根据这些描述产生代码,这些代码将用来生成或解析代表这些数据结构的字节流。 Google最初开发了Protocol Buffers用于内部使用。P...

阿里云Flink-自定义kafka format实践及踩坑记录(以protobuf为例)
问答 2023-02-14 来自:开发者社区

flinksql对接kafka的数据后,用什么format格式可以进行两表关联啊?

flinksql对接kafka的数据后,用什么format格式可以进行两表关联啊?

问答 2021-12-08 来自:开发者社区

Flink 1.9 SQL Kafka Connector,Json format,how to d

Flink 1.9 SQL Kafka Connector,Json format,how to deal with not json message? Hi community,when I write the flink ddl sql like this: CREATE TABLE kafka_src ( id varchar, a varchar, b TIMESTAMP, c TIM.....

问答 2021-12-01 来自:开发者社区

Upsert Kafka 的format 为什么要求是INSERT-ONLY的?

Hi all, 最近在测试Upsert Kafka,在验证的过程中,发现Validation的时候要求format的changelog-mode 必须是insert-only的,请问这是什么原因呢。 如果不是的话,请直接指正我,谢谢。*来自志愿者整理的flink邮件归档

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问