Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

format for duplicate table insert, unique key table upsert and delete messages #21

Open
alberttwong opened this issue Apr 26, 2024 · 0 comments

Comments

@alberttwong
Copy link

PRODUCER starrocks-sink-duplicate_table-insert-message
topic: postgres.public.customer
{
"col_001": 6,
"col_002": "AAAAAAAAGAAAAAAA",
"col_003": 213219,
"col_004": 6374,
"col_005": 27082,
"col_006": 2451883,
"col_007": 2451853,
"col_008": "Ms.",
"col_009": "Brunilda aaa bbb ccc ddd eee",
"col_010": "Sharp",
"col_011": "Y",
"col_012": 4,
"col_013": 12,
"col_014": 1925,
"col_015": "SURINAME",
"col_016": null,
"col_017": "[email protected]",
"col_018": 2452430,
"_sling_loaded_at": 1713464143
}

PRODUCER starrocks-sink-unique_table-delete-message
topic: postgres.public.customer
{
"col_001": 1,
"col_002": "AAAAAAAAGAAAAAAA",
"col_003": 213219,
"col_004": 6374,
"col_005": 27082,
"col_006": 2451883,
"col_007": 2451853,
"col_008": "Ms.",
"col_009": "Brunilda aaa",
"col_010": "Sharp",
"col_011": "Y",
"col_012": 4,
"col_013": 12,
"col_014": 1925,
"col_015": "SURINAME",
"col_016": null,
"col_017": "[email protected]",
"col_018": 2452430,
"_sling_loaded_at": 1713464143,
"__op": 1
}

PRODUCER starrocks-sink-unique_table-upsert-message
topic: postgres.public.customer
{
"col_001": 1,
"col_002": "AAAAAAAAGAAAAAAA",
"col_003": 213219,
"col_004": 6374,
"col_005": 27082,
"col_006": 2451883,
"col_007": 2451853,
"col_008": "Ms.",
"col_009": "Brunilda bbbccc",
"col_010": "Sharp",
"col_011": "Y",
"col_012": 4,
"col_013": 12,
"col_014": 1925,
"col_015": "SURINAME",
"col_016": null,
"col_017": "[email protected]",
"col_018": 2452430,
"_sling_loaded_at": 1713464143,
"__op": 0
}

@alberttwong alberttwong changed the title format for messages format for duplicate table insert, unique key table upsert and delete messages Apr 26, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant