inlong icon indicating copy to clipboard operation
inlong copied to clipboard

[INLONG-10238][Sort] MySQL connector support audit ID

Open XiaoYou201 opened this issue 1 year ago • 0 comments

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.

企业微信截图_e874eff6-387b-4dda-abd4-201fc3c5b3a2

XiaoYou201 avatar May 17 '24 03:05 XiaoYou201