使用 Avro Schema 中的数组生成 Kafka 消息

Question

我使用记录数组创建了 avro 模式

   [
    {
        "type": "record",
        "name": "BbbAvro",
        "fields": [
            {
                "name": "ddd",
                "type": "string"
            }
        ]
    },
    {
        "type": "record",
        "name": "AaaAvro",
        "fields": [
            {
                "name": "ccc",
                "type": "string"
            },
            {
                "name": "xxx",
                "type": "string"
            }
        ]
    },
    {
        "type": "record",
        "name": "MainAvro",
        "fields": [
            {
                "name": "bbb",
                "type": "BbbAvro"
            },
            {
                "name": "aaa",
                "type": "AaaAvro"
            }
        ]
    }
]

如果我使用 Java 代码生成消息（创建对象并发送），它可以正常工作，但如果我尝试手动发送 kafka 消息到主题，它就不起作用。

 {
    "aaa": {
        "ccc": "ccc",
        "xxx": "xxx"
    },
    "bbb": {
        "ddd": "ddd",
    }
}

如何手动生成消息？

Answer 1

使用任何在线编辑器将 JSON 消息转换为一行，然后尝试手动发送，尝试这个 https://www.text-utils.com/json-formatter/