Skip to content

Conversation

@nickdelnano
Copy link

@nickdelnano nickdelnano commented Nov 24, 2025

Add mysql table operation metrics. This produces metrics that are useful for monitoring

  • numRecordsOutByDataChangeRecordInsert
  • numRecordsOutByDataChangeRecordUpdate
  • numRecordsOutByDataChangeRecordDelete

table dimension is added with format table=db_table

I started from the diff of #3529 and added table dimension.

Testing

This code path is difficult to write thorough tests for. I have deployed it in my environment and confirm it works well. If a reviewer has any suggestions for test cases to add, please let me know.

@github-actions github-actions bot added docs Improvements or additions to documentation mysql-cdc-connector labels Nov 24, 2025
@leonardBang
Copy link
Contributor

@ruanhang1993 Would you like to help review this PR when you have time?

@nickdelnano nickdelnano force-pushed the nickdelnano/mysql-op-metrics branch from 5f889f7 to 2f64f78 Compare December 12, 2025 14:19
@nickdelnano nickdelnano force-pushed the nickdelnano/mysql-op-metrics branch from 2f64f78 to 9de8a76 Compare December 12, 2025 14:23
@nickdelnano
Copy link
Author

@ruanhang1993 @leonardBang can this PR get a reviewer please? This adds a useful improvement of mysql monitoring that would be great to get in master for all Flink CDC users.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

docs Improvements or additions to documentation mysql-cdc-connector

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants