pulsar 的 schema 是泛型接口，用于绑定类型 t 的序列化/反序列化逻辑，而非 java 泛型上界约束；其校验与兼容性依赖 schema registry、类型定义、版本策略及客户端协同，非泛型本身。
Schema 的正确用法：不是 extends，而是绑定
你写的是：Schema<user></user>，不是 Schema extends User>。Java 中 Schema 是一个泛型接口，其定义类似：
public interface Schema<t> { ... }</t>
所以实际使用时是：
Schema<user> schema = Schema.JSON(User.class);</user>Producer<user> producer = client.newProducer(schema).topic("user-topic").create();</user>Consumer<user> consumer = client.newConsumer(schema).topic("user-topic").subscribe();</user>
此时 Pulsar 客户端会在发送前将 User 对象序列化为符合 JSON Schema 的字节，在接收端自动反序列化为 User 实例 —— 类型安全由 Schema 实现类（如 JSONSchema、AvroSchema）保证，不是靠 Java 泛型擦除后的运行时检查。
Schema 校验：靠服务端 Schema Registry + 客户端显式启用
Pulsar 默认不强制校验，需主动开启。校验发生在消息发布时（生产者端），由 Broker 对比当前 Topic 已注册 Schema 与新消息 Schema 是否兼容：
- 确保生产者使用的
Schema<user></user>与 Topic 当前 Schema 元数据一致（名称、类型、结构） - 若 Topic 已注册
AvroSchema，而你传入JSONSchema，会直接拒绝（IncompatibleSchemaException） - 启用方式：Broker 配置
schemaValidationEnforced=true；客户端无需额外代码，但必须传入非 null Schema 实例
Schema 兼容性：由策略驱动，不是泛型自动处理
兼容性检查（如 BACKWARD、FORWARD、FULL）由 Pulsar Schema Registry 按策略执行，与 Java 泛型无关。例如：
- 升级
User类：新增字段email（可选），保留旧字段 → 满足 BACKWARD 兼容（老消费者仍能读） - 删除字段或改类型（如
int age→String age）→ 触发兼容性失败，Broker 拒绝注册新 Schema - 控制策略：通过
pulsar-admin schemas compatibility --compatibility BACKWARD -t persistent://tenant/ns/topic设置
泛型安全 + 运行时兼容：两个层次要分开看
Java 泛型只提供编译期类型提示，运行时被擦除；而 Schema 兼容是跨进程、跨语言的数据契约。真正保障端到端安全的方式是：
- 统一使用
Schema.JSON(User.class)或Schema.AVRO(User.class)，让序列化逻辑与类结构强绑定 - 所有团队共用 Schema Registry，禁止绕过 Schema 直接发 raw bytes
- 消费者端也使用相同
Schema<user></user>，避免byte[] → Object手动解析导致 ClassCast 或 NPE - 升级客户端时注意：Pulsar 3.0+ 对 Avro/JSON Schema 的反射支持更健壮，建议用 3.0.8+ 版本（已验证支持
LocalDateTime等新类型）
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
