[Improve][Sort] Split one record to multiple records when the physical data has more records for KafkaLoadNode

[yunqingmoswu]

Description

Split one record to multiple records when the physical data has more records for KafkaLoadNode.
It is only used for multiple sink scenario, for example, the raw data is:

    "data":[
        {
            "id":352,
            "price":1.14,
            "currency":"US",
            "order_time":"2022-08-16 18:59:09"
        },
        {
            "id":353,
            "price":1.22,
            "currency":"US",
            "order_time":"2022-08-16 18:59:09"
        }
    ],
    "type":"INSERT",
    "pkNames":[
        "id"
    ],
    "database":"inlong",
    "ts":1666772931248,
    "table":"orders"
}

and then it will be split into two records when writing as follows:

{
    "data":[
        {
            "id":352,
            "price":1.14,
            "currency":"US",
            "order_time":"2022-08-16 18:59:09"
        }
    ],
    "type":"INSERT",
    "pkNames":[
        "id"
    ],
    "database":"inlong",
    "ts":1666772931248,
    "table":"orders"
}
{
    "data":[
        {
            "id":353,
            "price":1.22,
            "currency":"US",
            "order_time":"2022-08-16 18:59:09"
        }
    ],
    "type":"INSERT",
    "pkNames":[
        "id"
    ],
    "database":"inlong",
    "ts":1666772931248,
    "table":"orders"
}

InLong Component

InLong Sort

Are you willing to submit PR?

• Yes, I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct