avro - Spring融合模式反序列化示例

Question

有没有人使用过 spring-kafka 2.0.0.Release 并创建了一个使用融合模式注册表作为反序列化消息源的消费者？如果是这样，你能给我举个例子吗？

我要解决的问题是我的 kafka 连接平台上有一个 Debezium CDC 连接器，它可以在事件发生时从 MongoDB 流式传输事件。我必须拦截这些事件转换并重新传输。要了解该事件，我必须反序列化有效负载。我目前卡在这一步。

Answer 1

萨斯特里

这个问题似乎在不久前得到解决，所以我想指出以下测试代码和其中的特定部分，您可以在其中配置 kafka schema-registry。请看一下，看看是否清楚或您需要更多帮助。