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&quot美元:"http://json-schema.org/draft-07/schema">

Ps:使用的schema太长

可能是什么问题?

Answer 1

我解决了这个问题:我只是添加use.latest.version: true从模式注册表的服务器获取模式。

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