littlebear-xbz commented on issue #6428:
URL: https://github.com/apache/seatunnel/issues/6428#issuecomment-1975850561
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
--
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]
