我使用带有模式注册表的 python confluent-kafka 1.5.0 来使用来自 kafka 的 avro 消息。
我只是消费者,无法访问管理生产者或经纪人或其他东西。
我知道主题名称,并且从消息字段中我也在模式注册表客户端中获取主题和名称空间,sr 客户端使用消息中的 schema_id 获取模式。
根据我的目标,在我开始消费之前,我需要方法获取模式(仅 id 或主题名称)。也就是说,我想手动按主题名称获取架构
请仔细阅读,我知道从消息中获取 schema_id 后如何手动获取模式。