Auto-split Hash Range

ghy · December 23, 2022, 4:17am

请问新加入一个消费者后，这个拆分的算法在哪里实现的，我没有找到。
KeySharedPolicyAutoSplit.java中没有任何线索，感谢。

codelipenghui · December 23, 2022, 6:26am

实现都是这个接口的子类

apache/pulsar/blob/38053b5d1babb2754212fecb1e1f81a529abb40f/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StickyKeyConsumerSelector.java#L27


      
          * under the License.
          */
          package org.apache.pulsar.broker.service;
          
          
import java.util.List;
          import java.util.Map;
          import org.apache.pulsar.broker.service.BrokerServiceException.ConsumerAssignException;
          import org.apache.pulsar.client.api.Range;
          import org.apache.pulsar.common.util.Murmur3_32Hash;
          
          
public interface StickyKeyConsumerSelector {
          
          
   int DEFAULT_RANGE_SIZE =  2 << 15;
          
          
   /**
              * Add a new consumer.
              *
              * @param consumer new consumer
              */
             void addConsumer(Consumer consumer) throws ConsumerAssignException;