inlong
inlong copied to clipboard
[INLONG-10238][Sort] MySQL connector support audit ID
Prepare a Pull Request
-
[INLONG-10238][Sort] Mysql connectors support audit ID
-
Fixes https://github.com/apache/inlong/issues/10238
-
parent issue: https://github.com/apache/inlong/issues/8803
Motivation
Mysql connector not support audit function. So this pr will make it support audit function.
Modifications
Modify Mysql connector source.when source receive data, it will send audit information at same time.Some implement are as follows:
Program will get the audit information from the incoming sql statement and pass it to the deserialization classes. During deserialization, the program will report the number of data received.