这篇文章将为大家详细讲解有关Pulsar Schema是什么意思，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。一 Pulsar Schema 基本概念
Schema是定义在topic上
Schema的更新策略是在命名空间定义。
以下图片是一个 schema JSON格式的例子
二 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
指定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 schem 香港云主机aInfo=Schema.JSON(UserModel.class).getSchemaInfo();
四 schema更新策略
设置schema策略方法
Namespaces namespaces=admin.namespaces();
namespaces.setSchemaAutoUpdateCompatibilityStrategy(“命名空间名称”, SchemaAutoUpdateCompatibilityStrategy.属性);
是否强制效验schema
namespaces.setSchemaValidationEnforced(“命名空间名称”, false);
这篇文章主要介绍“Python中的异常相关知识点”，在日常操作中，相信很多人在Python中的异常相关知识点问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Python中的异常相关知识点”的疑惑有所帮助！接下来，请跟着小编一起来学…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
