Kafka能否为消费者和生产者分别使用不同的Schema Registry?
Kafka支持对接多个Schema Registry吗?
答案是完全支持,具体说明如下:
- Kafka本身与Schema Registry是解耦状态,Schema Registry是独立的Schema管理服务组件,Kafka核心功能并不依赖或绑定特定的Schema Registry实例。
- 针对你的业务场景,消费环节可以单独配置Schema Registry A的地址及相关参数,用于解析源主题的消息;生产环节则配置Schema Registry B的地址,将处理后的新消息关联到B中的Schema并发送至目标主题。
- 实现时只需在消费者和生产者的配置中分别指定对应的Schema Registry地址即可,比如使用Confluent客户端时,分别给消费端和生产端的
schema.registry.url参数设置不同的地址。 - 需要注意确保两端的序列化/反序列化器(如
KafkaAvroSerializer/KafkaAvroDeserializer)各自指向正确的Schema Registry,避免出现Schema解析错误。
内容的提问来源于stack exchange,提问作者nate-sonicbottle
相关产品推荐
相关产品推荐

