cdc,tests: checksum of upstream & downstream mismatch

[pingyu]

Bug Report

1. Describe the bug

In integration test case http_api for Kafka sink, the checksum between upstream & downstream was mismatch:

Error: Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}
rawkv_data failed, Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}.
check diff failed 47-th time, retry later
[2024/02/13 16:40:51.902 +08:00] [WARN] [checksum.go:80] ["Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}"]
Error: Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}
rawkv_data failed, Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}.
check diff failed 48-th time, retry later
[2024/02/13 16:40:54.954 +08:00] [WARN] [checksum.go:80] ["Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}"]
Error: Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}
rawkv_data failed, Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}.
check diff failed 49-th time, retry later
[2024/02/13 16:40:58.008 +08:00] [WARN] [checksum.go:80] ["Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}"]
Error: Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}
rawkv_data failed, Upstream checksum {5706673269840752743 5000 573867} are not same with downstream {17428354121185495048 5000 573503}.
check diff failed 50-th time, retry later
check diff failed at last
stopping tidb cluster
stop tidb cluster finished
Error 1 occurred on 1 for sink kafka

See https://do.pingcap.net/jenkins/blue/organizations/jenkins/tikv%2Fmigration%2Fpull_integration_kafka_test/detail/pull_integration_kafka_test/45/pipeline/323/

do.pingcap.net.txt.zip

log-G04.tar.gz

2. Minimal reproduce step (Required)

3. What did you see instead (Required)

Test failed.

4. What did you expect to see? (Required)

Test succeed.

5. What is your migration tool and TiKV version? (Required)

• TiKV:
• TiKV CDC: [close #383] fix integration test case flow_control & stop_downstream #392 (25de855)
• TiKV BR:
• TiKV Online Bulk Load: