我发现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的同一个分区中的时许性是一致的，因此按照时间顺序统计出来的金额跟我们预期的是一致的。