tiflow
tiflow copied to clipboard
kafka(ticdc): fix kafka consumer doesn't check partition and old message
What problem does this PR solve?
Issue Number: close #11482
What is changed and how it works?
Add partition check and old message check about simple protocol
Check List
Tests
- Unit test
- Integration test
Questions
Will it cause performance regression or break compatibility?
Do you need to update user documentation, design documentation or monitoring documentation?
Release note
None