Closed yuzhichang closed 4 years ago
Custom sharding policy (by config shardingKey and shardingPolicy). By default, shard with (msg.Offset/batchSize)%ckNum. shardingKey is a column name. shardingPolicy is stripe,<size> or hash. The hash function used internally is xxHash64.
shardingKey
shardingPolicy
(msg.Offset/batchSize)%ckNum
stripe,<size>
hash
Custom sharding policy (by config
shardingKeyandshardingPolicy). By default, shard with(msg.Offset/batchSize)%ckNum.shardingKeyis a column name.shardingPolicyisstripe,<size>orhash. The hash function used internally is xxHash64.