in src/main/java/com/aliyun/openservices/aliyun/log/producer/ProducerConfig.java [251:262]
public void setBuckets(int buckets) {
if (buckets < BUCKETS_LOWER_LIMIT || buckets > BUCKETS_UPPER_LIMIT) {
throw new IllegalArgumentException(
String.format(
"buckets must be between %d and %d, got %d",
BUCKETS_LOWER_LIMIT, BUCKETS_UPPER_LIMIT, buckets));
}
if (!ShardHashAdjuster.isPowerOfTwo(buckets)) {
throw new IllegalArgumentException("buckets must be a power of 2, got " + buckets);
}
this.buckets = buckets;
}