我试过了
schema-registry-confluent
例如(消费者/生产者)在我本地安装的confluent 4.0.0中,当发送post请求并在侦听器中接收时,它可以发送“传感器”avro消息,但当我使用confluent 4.0.0附带的kafka avro控制台消费者工具查看发送的avro消息时,该工具引发了以下错误(a)。我还尝试使用kafka avro控制台生成工具发送的avro消息(该消息可以在kafka avro控制台消费工具中正确显示),它报告了以下错误(b)。给定的示例不支持confluent 4.0.0吗?非常感谢!
(a) 卡夫卡avro控制台使用者错误=>
错误运行consumer时出现未知错误:(kafka.tools.ConsoleConsumer$:107)
组织。阿帕奇。卡夫卡。常见的错误。SerializationException:反序列化id为-1的Avro消息时出错
原因:org。阿帕奇。卡夫卡。常见的错误。SerializationException:未知的魔法字节!
(b) 侦听器错误=>
组织。springframework。信息。转换器。MessageConversionException:无法读取JSON:字符#1,字节#7)处的UTF-32字符0x51473863(高于0x0010ffff)无效;嵌套的例外是java。伊奥。CharConversionException:字符#1,字节#7处的UTF-32字符0x51473863(高于0x0010ffff)无效
在org。springframework。信息。转换器。MappingJackson2MessageConverter。convertFromInternal(MappingJackson2MessageConverter.java:234)~[spring-messaging-5.1.0.BUILD-SNAPSHOT.jar!/:5.1.0.BUILD-SNAPSHOT]
