能否为Schema Registry的Subject创建别名/软链接以避免Schema重复？

当然可行，有两种主要方式能实现你的需求——既避免重复存储Schema，又不用大幅修改现有Kafka主题：

方式一：为Subject创建别名（直接复用已有Schema） #

Confluent Schema Registry支持通过API将新Subject关联到已存在的Schema ID，完全不需要重复上传Schema。具体操作步骤：

1. 查询目标Schema的ID
   先通过API获取你要复用的目标Subject（{env}.{level}.{schema_name}.{version}）对应的Schema ID：

   curl http://<schema-registry地址>/subjects/{env}.{level}.{schema_name}.{version}/versions/latest
   

   返回结果中的id字段就是需要的Schema ID。

2. 为主题Subject创建别名
   针对每个主题对应的{topicName}-value Subject，发送请求关联到上述Schema ID：

   curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
   --data '{"schemaId": 123}' \
   http://<schema-registry地址>/subjects/{topicName}-value/versions
   

   把123替换为实际的Schema ID，{topicName}替换成具体主题名即可。

完成后，Sink Connector使用topicNameStrategy生成的Subject会直接复用已有Schema，不会产生重复存储。

方式二：自定义Subject Name Strategy（一劳永逸） #

如果不想手动维护每个主题的别名，可以自定义一个Subject Name Strategy类，让Avro Converter直接生成你需要的目标Subject格式，跳过{topicName}-value的自动生成逻辑：

1. 实现自定义策略类
   编写Java类实现io.confluent.kafka.serializers.subject.SubjectNameStrategy接口，解析主题名的.分隔结构，提取env、level、schema_name字段，拼接成{env}.{level}.{schema_name}.{version}格式的Subject（版本号可根据需求固定或从主题额外提取）。

2. 配置Connector使用自定义策略
   在Sink Connector的配置中指定自定义策略类：

   value.converter=io.confluent.connect.avro.AvroConverter
   value.converter.schema.registry.url=http://<schema-registry地址>
   value.converter.subject.name.strategy=com.你的团队.CustomSchemaSubjectStrategy
   

这种方式无需手动维护别名，只要主题名格式符合约定，Converter就会自动使用正确的Subject，一次性解决所有主题的问题，但需要开发并部署自定义类到Connector的运行环境中。

注意事项 #

• 使用别名时，要确保目标Schema的兼容性规则符合业务需求，避免后续Schema演进时出现兼容性问题。
• 自定义策略时，要处理主题名格式不符合约定的异常情况，防止Connector运行报错。
• 两种方式都不需要修改现有Kafka主题名，完全满足你的要求。

内容的提问来源于stack exchange，提问作者Jin Ma