Json 模式注册表 spring cloud kafka

Question

我使用 spring cloud stream kafka，我对 json 模式注册表有疑问，我用 confluent 的 api 保存我的模式，但我总是遇到这个问题

org.springframework.messaging.MessageHandlingException：发生错误 在消息处理程序中 [org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$ProducerConfigurationMessageHandler@65ffd83e]; 嵌套异常是 org.apache.kafka.common.errors.SerializationException: 错误 检索 JSON 架构： {"$schema":"http://json-schema.org/draft-07/schema#"

Ps：使用的schema太长了

问题可能是什么？

Answer 1

我解决了问题：我只是添加

use.latest.version: true

从模式注册表的服务器获取模式。

如果没有这个选项，Spring 将不会获得模式的实际版本。