操作场景
在分布式消息流系统中,消息通常以无结构的“原始字节”形式传输,这要求发送端(Producer)和接收端(Consumer)必须预先在代码中实现相同的序列化与反序列化逻辑。而 Schema 作为 Pulsar 声明式的数据结构契约,会被注册并存储在 Schema 注册表中,用于明确定义 Topic 中流转消息的数据类型、字段名称、数据格式及约束条件。
查看 Schema
操作步骤
1. 登录 TDMQ Pulsar 版控制台。
2. 在左侧导航栏选择 Topic 管理,找到目标 Topic 单击后,进入 Topic 详情页面。切换 Schema 管理页签。
3. 在 Schema 管理子页,查看当前 Topic 的 Schema 信息。

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

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

删除 Schema 版本
操作步骤
1. 登录 TDMQ Pulsar 版控制台。
2. 在左侧导航栏选择 Topic 管理,找到目标 Topic 单击后,进入 Topic 详情页面。切换 Schema 管理页签。
3. 在 Schema 管理子页内,点击删除 Schema 进行删除操作。

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