我有一个Spring云流Kafka消费者消费的avro记录。
@StreamListener("sample") public void recieve(GenericData.Record record)
这个avro记录可以包含一个logicaltype,它是十进制数据的字节缓冲区转换。
现在,在使用传入记录时,这就是我所看到的逻辑类型字段的值。 "DECVAL":"java.nio.HeapByteBuffer[pos=0 lim=1 cap=1]"
当记录被消耗时,我在代码中看到下面的警告消息。
[org.apache.avro.logicaltypes][logmessage:ignoring invalid 名称的逻辑类型:decimal]
如何正确使用数据?
暂无答案!
目前还没有任何答案,快来回答吧!