您好,登錄后才能下訂單哦!
java中Pulsar Schema是什么?一般大家對Schema的了解可能停留在概念的層面上,而對于Schema在Pulsar的使用方法了解相對較少。今天就跟大家聊聊Schemar的使用方法
一 Pulsar Schema 基本概念
Schema是定義在topic上
Schema的更新策略是在命名空間定義。
以下圖片是一個 schema JSON格式的例子
字段 | 說明 |
---|---|
name | Schema 名稱(發(fā)現(xiàn)和topic名稱相同) |
type | Schema 類型,類型常用的JSON格式,其他詳見官方文檔 |
schema | Schema 數(shù)據(jù)是一個由 8 位無符號字節(jié)和模式類型特定組成的序列,這一屬性可能是內(nèi)部使用 |
schemaDefinition | 具體業(yè)務(wù)數(shù)據(jù)結(jié)構(gòu) |
properties | 存放用戶自定義屬性 |
二 Schema的生成
通過3種途徑生成Topic上的schema
1 producer 生產(chǎn)者
2 consumer 消息者
3 管理API
topic上默認沒有schema,以上3種途徑誰先訪問Topic,就按誰的schema結(jié)構(gòu)做為第一個版本。
三 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 創(chuàng)建schema
schemas.createSchema("topic名稱",schemaInfo);
關(guān)于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更新策略
設(shè)置schema策略方法
Namespaces namespaces=admin.namespaces();
namespaces.setSchemaAutoUpdateCompatibilityStrategy("命名空間名稱", SchemaAutoUpdateCompatibilityStrategy.屬性);
是否強制效驗schema
namespaces.setSchemaValidationEnforced("命名空間名稱", false);
假設(shè)你有一個包含三個方案的主題 (V1、V2和V3),V1 是最老的,V3 是最新的
屬性 | 說明 | 檢查哪個 schema |
---|---|---|
Full | 架構(gòu) V3 和 V2 之間向后和向前兼容 (默認策略) | 最新版本 |
FullTransitive | 架構(gòu) V3、V2 和 V1 之間向后和向前兼容 | 所有之前的版本 |
AlwaysCompatible | 可以更改schema結(jié)構(gòu),結(jié)構(gòu)不同會產(chǎn)生新版本 | 所有之前的版本 |
AutoUpdateDisabled | 禁用更新schema結(jié)構(gòu) | 無 |
Backward | 使用 schema V3 的消費者可以處理生產(chǎn)者使用 schema V3 或 V2 編寫的數(shù)據(jù) | 最新版本 |
BackwardTransitive | 使用 schema V3 的消費者可以處理生產(chǎn)者使用 schema V3、V2 或 V1 編寫的數(shù)據(jù)。 | 所有之前的版本 |
Forward | 使用 schema V3 或 V2 的消費者可以處理生產(chǎn)者使用 schema V3 編寫的數(shù)據(jù)。 | 最新版本 |
ForwardTransitive | 使用 schema V3、V2 或 V1 的消費者可以處理生產(chǎn)者使用 schema V3 編寫的數(shù)據(jù) | 所有之前的版本 |
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。