无法使用kafka流将avro对象写入另一个主题

nc1teljy  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(255)

我有一个kafka流应用程序,它读取avro消息并对其进行一些转换,然后将其写入另一个主题。我可以阅读avro消息没有任何问题,但当写另一个主题,我得到以下错误。这个特定的错误代码在互联网上找不到。
原因:org.apache.kafka.common.errors.serializationexception:注册avro架构时出错:{“type”:“record”,“name”:“value”,“namespace”:“com.github.jcustenborder.kafka.connect.model”,“fields”:[{“name”:“storeid”,“type”:[“null”,“string”],“default”:null},{“name”:“transactionid”,“type”:[“null”,“string”],“default”:null},{“name”:“transactiontimestarchivo”,“type”:[“null”,“string”],“default”:null},{“name”:“transactiontimestamp”,“type”:[“null”,“string”],“default”:null},{“name”:“itembarcode”,“type”:[“null”,“string”],“default”:null},{“name”:“iteminternalcode”,“type”:[“null”,“string”],“default”:null},{“name”:“itemdescription”,“type”:[“null”,“string”],“default”:null},{“name”:“itemsalevolume”,“type”:[“null”,“string”],“default”:null},{“name”:“itemunitprice”,“type”:[“null”,“string”],“default”:null},{“name”:“itemtotalsale”,“type”:[“null”,“string”],“default”:null},{“name”:“transactiontotalsale”,“type”:[“null”,“string”],“default”:null},{“name”:“itemcegory”,“type”:[“null”,“string”],“default:null},{“name”:“isweight”,“type”:[“null”,“string”],“default”:null}],“connect.name”:“com.github.jcustenborder.kafka.connect.model.value”}原因:io.confluent.kafka.schemaregistry.client.rest.exceptions.restclientexception:意外字符('<'(代码60)):需要有效值(数字、字符串、数组、对象、'true'、'false'或'null')
下面是一个线程,它讨论了非常相同的错误代码,但有人得出结论,线程将此问题与身份验证联系起来。目前,我们正在运行的架构注册表尚未保护它。它是一个没有这种安全性的普通dev服务器。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题