kafka consumer needs to correctly check partition and old message #11482
Labels
area/ticdc
Issues or PRs related to TiCDC.
component/test
Unit tests and integration tests component.
type/enhancement
The issue or PR belongs to an enhancement.
What did you do?
run kafka consumer
What did you expect to see?
No response
What did you see instead?
simple protocol doesn't check partition and old message
Versions of the cluster
Upstream TiDB cluster version (execute
SELECT tidb_version();
in a MySQL client):(paste TiDB cluster version here)
Upstream TiKV version (execute
tikv-server --version
):(paste TiKV version here)
TiCDC version (execute
cdc version
):(paste TiCDC version here)
The text was updated successfully, but these errors were encountered: