融合kafka生产者avro架构错误ClientError：架构解析失败：未知命名架构

Question

我在Kafka的制作人那个里工作，推动主题中的信息。我用的是融合的Kafka。

github上的喜欢问题

下面是我的模式。avsc文件。

Keys.avsc

{
    "namespace": "io.codebrews.schema.test",
    "type": "record",
    "name": "Keys",
    "fields": [
        {
            "name": "name",
            "type": "string"
        },
        {
            "name": "email",
            "type": "string"
        }
    ]
}

测试.avsc

{
    "namespace": "io.codebrews.schema.test",
    "type": "record",
    "name": "Subscription",
    "fields": [
        {
            "name": "test",
            "type": "string"
        },
        {
            "name": "keys",
            "type": "io.codebrews.schema.test.Keys"
        }
    ]
}

生产者.py

key_schema, value_schema = load_avro_schema_from_file('Subscription.avsc')

try:
    producer = avro.AvroProducer(producer_config, default_key_schema=key_schema, default_value_schema=value_schema)
except Exception as e:
    raise e

def load_avro_schema_from_file(schema_file):
    key_schema_string = """
    {"type": "string"}
    """

    key_schema = avro.loads(key_schema_string)
    value_schema = avro.load("./avro/" + schema_file)

    return key_schema, value_schema

当我尝试注册Keys.avsc时，它工作正常，没有错误。但是当我尝试注册Test.avsc之后注册Keys.avsc。我得到以下错误。

confluent_kafka.avro.error。ClientError：架构分析失败：未知的命名架构“io.codebrews.Schema.test”。键，已知名称：[“io.codebrews.schema.test.Subscription”]。

手动注册架构后。

{
    "namespace": "io.codebrews.schema.test",
    "type": "record",
    "name": "Subscription",
    "fields": [
        {
            "name": "test",
            "type": "string"
        },
        {
            "name": "keys",
            "type": "Keys"
        }
    ]
}

当在我的主题推送消息时，我得到以下错误。

ClientError：不兼容的Avro架构：409消息：{error\u code:409，'消息'：'正在注册的架构与主题“测试值”的早期架构不兼容。

我做错什么了吗？

还有谁能帮我停止python中的自动模式注册吗？

Answer 1

错误与解析器有关，而与注册表注册无关。。。

您的AVSC文件需要完全包含所有记录类型。当解析器读取一个文件时，它无法了解其他文件

如果您从一个AVDL文件开始，然后将其转换为AVSC，那么这些记录会正确地嵌入到外部记录中。

具体来说，

"fields" :[{
  "name": "keys",
  "type": {
       "type": "record", 
       "namespace": "io.codebrews.schema.test.Keys", 
       ... 
  } 
}