kafka consumer needs to correctly check partition and old message

[wk989898]

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)