java中脉冲星模式是什么?一般大家对模式的了解可能停留在概念的层面上,而对于模式在脉冲星的使用方法了解相对较少。今天就跟大家聊聊Schemar的使用方法
一脉冲星模式基本概念
模式是定义在主题上
模式的更新策略是在命名空间定义。
以下图片是一个JSON模式格式的例子
二模式的生成
通过3种途径生成的话题上的模式
1生产商生产者
2消费者消息者
3管理API
主题上默认没有模式,以上3种途径谁先访问的话题,就按谁的模式结构做为第一个版本。
三java管理API
1建立连接
PulsarAdmin管理=PulsarAdmin.builder (),,,,,,,,,,,,,.serviceHttpUrl (url) .build ();
模式模式=admin.schemas();//获取模式管理对象
2查看schmea
指定主题上模式所有版本
List
指定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 是最新的
属性说明检查哪个 schemaFull架构 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 编写的数据所有之前的版本以上就是介绍，详细使用情况还得要大家自己使用过才能知道具体要领。如果想阅读更多相关内容的文章，欢迎关注行业资讯频道！
