Kafka Connect JSON Schema $ref标签支持及相关处理问题咨询

问题1：JsonConverter是否未处理$ref逻辑 #

你的判断完全准确，Apache Kafka 原生的JsonConverter.java模块确实没有实现任何$ref标签的解析处理逻辑，该类的Schema转换逻辑仅做JSON结构的递归遍历，遇到$ref字段不会触发解引用操作，相关处理逻辑也没有放在Kafka Connect的其他原生模块中，原生实现仅支持无引用的扁平化JSON Schema到Connect Schema对象的转换。

问题2：Schema Registry是否支持子定义引用 #

Schema Registry完全支持同一份Schema内部的子定义引用，也支持跨Schema的外部引用。它的解引用逻辑封装在自身的json-schema-provider模块中，核心依赖成熟的第三方JSON Schema解析库完成$ref的定位、替换操作，你自己实现转换逻辑时可以直接使用Everit、NetworkNT等开源JSON Schema解析库的解引用能力，无需从零开发相关逻辑。

问题3：是否需要提前内联所有引用 #

如果你使用原生Kafka Connect的JsonConverter组件，确实需要在提交JSON Schema到Schema Registry之前，提前将所有$ref内联为无引用的扁平化结构，以此规避原生组件不支持$ref的问题。
如果你是自己开发定制转换逻辑，无需提前内联引用，你可以在从Schema Registry获取到完整的Schema字符串后，先调用JSON Schema解析库完成解引用操作，再转换为Connect的Schema对象即可，提前内联仅为适配原生组件缺陷的临时方案，不是标准流程。

内容的提问来源于stack exchange，提问作者Eric Broda