sunxiaojian commented on issue #6428:
URL: https://github.com/apache/seatunnel/issues/6428#issuecomment-1978608954
> Hi, for my usage scebario, the easiest way is to add a tableId into the
json format(i not know this will affect the connector which uses the
debezium-json as the source )， like this
>
> ```
>
{"before":null,"after":{"id":132,"name":"abc","age":21,"created_at":"2024-02-29T17:40:04.512663"},"op":"c","tableId":"db_plumc.app_plumc.flink_sysc_test"}
> ```
>
> If cdc sink the data directly in the original data format, of course, it
also solve this problem, and later it will be more flexible, but for me
personally i think the learning cost may be a little higher for beginners
It's just simple JSON format data, not so complicated, and the official
documentation of Debezium is also quite detailed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
