What did you do?
- start a changefeed with kafka sink
- write some data (100mb/s)
- stop writing the data
What did you expect to see?
No response
What did you see instead?
After stopping to write data, the sink write bytes increase

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):
What did you do?
What did you expect to see?
No response
What did you see instead?
After stopping to write data, the sink write bytes increase

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):release-8.5