如何自定义 Spring Cloud Stream Schema 注册表以与无 SQL 后端一起使用

Question

我正在尝试将 Spring Cloud Stream SchemaRegistry 与 MongoDB 集成作为 SchemaRegistry 后端。我只是想知道在当前的实施情况下这是否可行以及需要进行哪些更改才能实现这一目标？

我已经浏览了 Spring Cloud Stream Schema Registry 核心部分，似乎需要做很多核心更改才能实现这一目标。

Answer 1

按照目前的实施情况，这是否可行

该文档非常明确地说明了您的选项

1. H2
2. MySQL（或兼容）
3. PostgreSQL（或兼容）
4. 融合模式注册表（或兼容）

MongoDB 与这些数据库的任何客户端都不“兼容”。

需要进行哪些改变才能实现这一目标

您需要一个至少可以支持的 Mongo 集合模式

1. 通过id获取
2. 通过“主题名称”获取
3. 通过“主题”的“版本”获取，其中版本是非负整数或“最新”

这可以内置到 Kafka 客户端库本身中，不必“插入”任何Registry 产品；这主要是所有注册中心提供的——围绕简单的 REST 或数据库客户端的本机 Kafka 序列化器和反序列化器实现。 （所有提到的选项都是开源的，去看看实现）