我用avro库写了一个示例。它从模式User生成java类源代码record User。java.lang.ClassCastException: org.apache.avro.util.Utf8 cannot be cast to java.lang.String如何将org.apache.avro.util.Utf8转换为java String?
我正在使用python来读取来自不同主题的消息。一些主题将它们的消息编码为普通的JSON,而其他主题则使用Avro二进制序列化,其中包含合流模式注册表。当我收到一条信息时,我需要知道它是否必须被解码。目前,我只依赖于二进制编码消息以值为零的MAGIC_BYTE开头的事实:
from confluent_kafka.cimpl import Con