kafka-python：avro.io.SchemaResolutionException：无法访问分支索引55与2个分支的联合

Question

我使用kafka python 2.0.1来使用avro数据。以下是我尝试过的代码：

from kafka import KafkaConsumer
import avro.schema
from avro.io import DatumReader, BinaryDecoder
import io

schema_path="schema.avsc"
schema = avro.schema.parse(open(schema_path).read())
reader = DatumReader(schema)


consumer = KafkaConsumer(
        bootstrap_servers='xxx.xxx.xxx.xxx:9093',
        security_protocol='SASL_SSL',
        sasl_mechanism = 'GSSAPI',
        auto_offset_reset = 'latest',
        ssl_check_hostname=False,
        api_version=(1,0,0))

consumer.subscribe(['test'])

for message in consumer:
       message_val = message.value
       print(message_val)
       bytes_reader = io.BytesIO(message_val)
       bytes_reader.seek(5)    
       decoder = avro.io.BinaryDecoder(bytes_reader)    
       record = reader.read(decoder)
       print(record)

我得到以下错误:

avro . io . schemaresolutionexception:无法访问具有2个分支的联合的分支索引55编写器的架构:[ "null "，" int" ]读取器的架构:[ "null "，" int" ]

任何人都可以建议这个错误的可能原因是什么？我已经按照这个线程跳过了最初的5个字节：

如何从Kafka解码/反序列化Avro与Python

Answer 1

我让它工作了。问题是引用了错误的架构。谢谢。