PulsarSchemaPulsarschema使您能够在构建和处理从简单类型到更复杂的应用程序特定类型的消息时使用特定于语言的数据类型。类型安全（序列化和反序列化）Schema帮助Pulsar保留数据在其他系统中的原始含义.value("HelloPulsar!").send();Consumerconsumer=client.newConsumer(Schema.STRING).subscribe();consumer.receive();Complextype1.keyvaluekey/valuepair.Schema>schema=Schema.KeyValue(Schema.INT32,Schema.STRING,KeyValueEncodingType.SEPARATED);//生产者Producer>producer=client.newProducer(schema).topic(TOPIC）。创造（）;finalintkey=100;finalStringvalue="value-100";producer.newMessage().value(newKeyValue<>(key,value)).send();//ConsumerConsumer>consumer=client.newConsumer(schema).topic(TOPIC).subscriptionName(SubscriptionName).subscribe();Message>msg=consumer.receive();2.structAVRO,JSON,andProtobuf.Producerproducer=client.newProducer(Schema.AVRO(User.class)).create();producer.newMessage().value(User.builder().userName("pulsar-user").userId(1L).build()).send();Consumerconsumer=client.newConsumer(Schema.AVRO(User.class)).subscribe();Useruser=consumer.receive();Schema工作方式(Howdoesschemawork)ProducerConsumerSchema管理(Schema手动管理)查询Schema$$PULSAR_HOME/bin/pulsar-adminschemas\getpersistent://public/default/spirit-avro-topic$$PULSAR_HOME/bin/pulsar-adminschemas\getpersistent://public/default/spirit-avro-topic\--version=2更新Schema$$PULSAR_HOME/bin/pulsar-adminschemasupload\persistent://public/default/test-topic\--文件名$PULSAR_HOME/connectors/json-schema.json提取Schema$$PULSAR_HOME/bin/pulsar-adminschemas\extractpersistent://public/default/test-topic\--classnamecom.cloudwise.modal.Packet\--jar~/cloudwise-pulsar-1.0.0-RELEASE.jar\--typejsonpublicvoidschemaInfo(){System.out.println("AvroSchema:"+AvroSchema.of(SeedEvent.class).getSchemaInfo());System.out.println("Schema.AVRO:"+Schema.AVRO(SeedEvent.class).getSchemaInfo());}删除Schema$$PULSAR_HOME/bin/pulsar-adminschemas\deletepersistent://public/default/spirit-avro-topic写在最后近年来，在AIOps领域高速发展的大背景下，各行业对IT工具、平台能力、解决方案、AI场景、可用数据集的迫切需求呈爆发式增长。AIOps社区于3月发布，旨在竖起开源大旗，为各行业的客户、用户、研究人员和开发者打造一个活跃的用户和开发者社区，共同贡献和解决行业问题，推动技术发展在这个领域里。社区先后开源了数据可视化与编排平台——FlyFish、运维管理平台OMP、云服务管理平台——Moore平台、Hours算法等产品。视觉编排平台-FlyFish：项目介绍：https://www.cloudwise.ai/flyF...Github地址：https://github.com/CloudWise-...Gitee地址：https://gitee.com/CloudWise/f...行业案例：https://www.bilibili.com/vide...部分大屏案例：可添加小助手（xiaoyuerwie）注：飞鱼。加入开发者交流群，与行业大咖1V1交流！您还可以通过小助手获取云智慧AIOps信息，了解飞鱼的最新进展！ApachePulsar系列阅读（一）：PulsarvsKafkaApachePulsar（二）：Pulsar消息机制
