bytebuffer逻辑类型转换

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

我有一个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]
如何正确使用数据?

暂无答案!

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

相关问题