TIDB的CDC到kafka的问题

我发现TIDB的CDC下沉到kafka时在发送到kafka的哪个分区时有些问题,不能自己选择表的某个字段作为分区策略,只能使用主键或唯一索引,这就有问题了,问题如下:
假设流水表有如下数据:
|流水号|客户编号|消费金额|消费时间|
|001|CNT01|10|1s|
|002|CNT01|6|2s|
|003|CNT01|5|3s|
|004|CNT01|3|4s|

需求是实时统计客户消费的总金额,很明显按照时间顺序统计出来的金额分别是:10,16,21,24
但是如果sink的kafka的分区数是3,并且按照主键(即流水号)输出到topic中,假设partition2慢了,结果是partition3的数据先到达kafka的计算逻辑中,那么按照顺序统计出来的金额分别是:10,15,21,24
这明显就不对了。
如果在sink到kafka的partition时可以自己指定分区策略,比如我这里指定客户编号作为分区策略,那么这4条数据会根据先后顺序来到同一个分区中,kafka的同一个分区中的时许性是一致的,因此按照时间顺序统计出来的金额跟我们预期的是一致的。

请问是什么版本?

v6.1.0
另外,我觉得这与版本无关吧,这只与场景和kafka的partition有关,只不过希望tidb的cdc去适配它

自定义分发规则可以满足要求吗?
https://docs.pingcap.com/zh/tidb/stable/manage-ticdc#自定义-kafka-sink-的-topic-和-partition-的分发规则

满足不了,您给的链接是自定义到表这一级别,schema.table
我的建议是比表级别更细致一些,到字段级别,schema.table.column