我发现的解决方案是我可以用python处理kafka消息，例如用kafka python库，或者合流kafka python，然后我将用avro阅读器解码这些消息。
编辑：以下是我如何做到这一点的更新：
我以为avro库只是读取avro文件，但它实际上解决了解码kafka消息的问题，如下所示：我首先导入库并将schema文件作为参数，然后创建一个函数将消息解码到字典中，我可以在consumer循环中使用。

from confluent_kafka import Consumer, KafkaError
from avro.io import DatumReader, BinaryDecoder
import avro.schema

schema = avro.schema.Parse(open("data_sources/EventRecord.avsc").read())
reader = DatumReader(schema)

def decode(msg_value):
    message_bytes = io.BytesIO(msg_value)
    decoder = BinaryDecoder(message_bytes)
    event_dict = reader.read(decoder)
    return event_dict

c = Consumer()
c.subscribe(topic)
running = True
while running:
    msg = c.poll()
    if not msg.error():
        msg_value = msg.value()
        event_dict = decode(msg_value)
        print(event_dict)
    elif msg.error().code() != KafkaError._PARTITION_EOF:
        print(msg.error())
        running = False