Pulsar Schema是什么意思

這篇文章將為大家詳細(xì)講解有關(guān)Pulsar Schema是什么意思，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

一 Pulsar Schema 基本概念
Schema是定義在topic上
Schema的更新策略是在命名空間定義。
以下圖片是一個(gè) schema JSON格式的例子

二 Schema的生成
通過(guò)3種途徑生成Topic上的schema
1 producer 生產(chǎn)者
2 consumer 消息者
3 管理API
topic上默認(rèn)沒(méi)有schema,以上3種途徑誰(shuí)先訪問(wèn)Topic,就按誰(shuí)的schema結(jié)構(gòu)做為第一個(gè)版本。
三 JAVA 管理 API
1 建立連接
PulsarAdmin admin = PulsarAdmin.builder()                          .serviceHttpUrl(url).build();
Schemas schemas=admin.schemas();//獲取schemas管理對(duì)象
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對(duì)象的生成
1)可以通過(guò)RecordSchemaBuilder類型
RecordSchemaBuilder recordSchemaBuilder = SchemaBuilder.record("schemaName");
recordSchemaBuilder.field("ww").type(SchemaType.INT32);
SchemaInfo schemaInfo = recordSchemaBuilder.build(SchemaType.JSON);
2)也可以通過(guò)Schema
SchemaInfo schemaInfo=Schema.JSON(UserModel.class).getSchemaInfo();
四 schema更新策略
設(shè)置schema策略方法
Namespaces namespaces=admin.namespaces();
namespaces.setSchemaAutoUpdateCompatibilityStrategy("命名空間名稱", SchemaAutoUpdateCompatibilityStrategy.屬性);
是否強(qiáng)制效驗(yàn)schema
namespaces.setSchemaValidationEnforced("命名空間名稱", false);

假設(shè)你有一個(gè)包含三個(gè)方案的主題 (V1、V2和V3)，V1 是最老的，V3 是最新的

關(guān)于“Pulsar Schema是什么意思”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。