帮你快速理解、总结文档立即下载

Schema 管理

最近更新时间:2026-07-20 16:24:31

我的收藏

操作场景

在分布式消息流系统中,消息通常以无结构的“原始字节”形式传输,这要求发送端(Producer)和接收端(Consumer)必须预先在代码中实现相同的序列化与反序列化逻辑。而 Schema 作为 Pulsar 声明式的数据结构契约,会被注册并存储在 Schema 注册表中,用于明确定义 Topic 中流转消息的数据类型、字段名称、数据格式及约束条件。

查看 Schema

操作步骤

2. 在左侧导航栏选择 Topic 管理,找到目标 Topic 单击后,进入 Topic 详情页面。切换 Schema 管理页签。
3. 在 Schema 管理子页,查看当前 Topic 的 Schema 信息。

4. 点击版本对比,可对不同 Schema 历史版本数据结构进行比较:

5. 点击 Schema 列表操作列查看详情,以对特定 Schema 版本进行查看。


删除 Schema 版本

操作步骤

2. 在左侧导航栏选择 Topic 管理,找到目标 Topic 单击后,进入 Topic 详情页面。切换 Schema 管理页签。
3. 在 Schema 管理子页内,点击删除 Schema 进行删除操作。

说明:
Schema 不支持单独删除其中某一个版本,而只能整体彻底删除。
在生产实践中,如果您的 Schema 发生写错或过时,不要试图删除版本,而是直接发布新版本进行覆盖(Pulsar 的兼容性策略会保证新版本能够平滑兼容老数据)。
目前 Pulsar 集群 Topic 的 Schema 管理仅支持查看和删除。