ksqlDB与Apicurio Registry集成：Debezium兼容性问题求助

针对你遇到的ksqlDB与Apicurio Registry集成时的Debezium兼容性问题，以下是具体解决方案：

一、让ksqlDB使用Apicurio官方/registry/v2 API的可行方案 #

ksqlDB原生仅支持Confluent Schema Registry的API规范，无法直接适配Apicurio的/registry/v2 API（缺少/subjects接口支持），可通过以下两种方式实现适配：

• API网关转发转换：在ksqlDB与Apicurio之间部署API网关，将ksqlDB发出的Confluent风格请求（如/subjects、/subjects/{subject}/versions）转换为Apicurio v2 API的对应操作。例如将/subjects请求映射到Apicurio的/registry/v2/groups/{group}/artifacts接口，实现schema主题的查询。
• 自定义Schema Registry客户端：修改ksqlDB源码，替换默认的Confluent Schema Registry客户端实现，使其适配Apicurio v2 API的接口规范。此方法开发成本较高，仅适合有定制化需求的场景。

二、强制ksqlDB使用Global-Id查询Schema的配置方法 #

使用Apicurio的/ccompat/v6兼容API时，默认会将Confluent风格的Schema ID映射为Apicurio的Content-Id，导致与Debezium写入的Global-Id不匹配，可通过配置修改映射规则：

1. 修改Apicurio Registry的配置文件，添加或修改以下配置项：

apicurio.registry.compatibility.confluent.id-mapping=globalId

2. 重启Apicurio Registry服务，使配置生效。
3. 重新启动ksqlDB服务，确保其连接到更新后的Apicurio兼容API。

配置完成后，ksqlDB查询Schema时会将消息中的Schema ID当作Global-Id去Apicurio中查找，与Debezium写入的ID保持一致，即可解决如下反序列化错误：

ERROR {"type":0,"deserializationError":{"target":"value","errorMessage":"Error deserializing message from topic: debezium-topic-1","recordB64":null,"cause":["Failed to deserialize data for topic debezium-topic-1 to Avro: ","Error retrieving Avro value schema for id 96","No content with id/hash 'contentId-96' was found.; error code: 40403"]

验证步骤 #

• 发送测试消息到Debezium生成的topic（如debezium-topic-1）
• 查看ksqlDB日志，确认反序列化错误消失
• 登录Apicurio控制台，检查Schema的Global-Id是否与消息中携带的Schema ID一致

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