溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章將為大家詳細講解有關Pulsar Schema是什么意思，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。
一 Pulsar Schema 基本概念
Schema是定義在topic上
Schema的更新策略是在命名空間定義。
以下圖片是一個 schema JSON格式的例子
| 字段 | 說明 |
|---|---|
| name | Schema 名稱(發現和topic名稱相同) |
| type | Schema 類型,類型常用的JSON格式，其他詳見官方文檔 |
| schema | Schema 數據是一個由 8 位無符號字節和模式類型特定組成的序列,這一屬性可能是內部使用 |
| schemaDefinition | 具體業務數據結構 |
| properties | 存放用戶自定義屬性 |
二 Schema的生成
通過3種途徑生成Topic上的schema
1 producer 生產者
2 consumer 消息者
3 管理API
topic上默認沒有schema,以上3種途徑誰先訪問Topic,就按誰的schema結構做為第一個版本。
三 JAVA 管理 API
1 建立連接
PulsarAdmin admin = PulsarAdmin.builder() .serviceHttpUrl(url).build();
Schemas schemas=admin.schemas();//獲取schemas管理對象
2 查看schmea
指定topic上schema所有版本
List<SchemaInfo> allSchemaInfo=schemas.getAllSchemas("topic名稱");
指定topic上schema最新版本
SchemaInfo snedschemaInfo=schemas.getSchemaInfo("topic名稱");
3 刪除schmea
schemas.deleteSchema("topic名稱")
4 創建schema
schemas.createSchema("topic名稱",schemaInfo);
關于schemaInfo對象的生成
1)可以通過RecordSchemaBuilder類型
RecordSchemaBuilder recordSchemaBuilder = SchemaBuilder.record("schemaName");
recordSchemaBuilder.field("ww").type(SchemaType.INT32);
SchemaInfo schemaInfo = recordSchemaBuilder.build(SchemaType.JSON);
2)也可以通過Schema
SchemaInfo schemaInfo=Schema.JSON(UserModel.class).getSchemaInfo();
四 schema更新策略
設置schema策略方法
Namespaces namespaces=admin.namespaces();
namespaces.setSchemaAutoUpdateCompatibilityStrategy("命名空間名稱", SchemaAutoUpdateCompatibilityStrategy.屬性);
是否強制效驗schema
namespaces.setSchemaValidationEnforced("命名空間名稱", false);
假設你有一個包含三個方案的主題 (V1、V2和V3)，V1 是最老的，V3 是最新的
| 屬性 | 說明 | 檢查哪個 schema |
|---|---|---|
| Full | 架構 V3 和 V2 之間向后和向前兼容 (默認策略) | 最新版本 |
| FullTransitive | 架構 V3、V2 和 V1 之間向后和向前兼容 | 所有之前的版本 |
| AlwaysCompatible | 可以更改schema結構,結構不同會產生新版本 | 所有之前的版本 |
| AutoUpdateDisabled | 禁用更新schema結構 | 無 |
| Backward | 使用 schema V3 的消費者可以處理生產者使用 schema V3 或 V2 編寫的數據 | 最新版本 |
| BackwardTransitive | 使用 schema V3 的消費者可以處理生產者使用 schema V3、V2 或 V1 編寫的數據。 | 所有之前的版本 |
| Forward | 使用 schema V3 或 V2 的消費者可以處理生產者使用 schema V3 編寫的數據。 | 最新版本 |
| ForwardTransitive | 使用 schema V3、V2 或 V1 的消費者可以處理生產者使用 schema V3 編寫的數據 | 所有之前的版本 |
關于“Pulsar Schema是什么意思”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
