com.taobao.metamorphosis.client.consumer
类 DefaultLoadBalanceStrategy

java.lang.Object
  继承者 com.taobao.metamorphosis.client.consumer.DefaultLoadBalanceStrategy
所有已实现的接口:
LoadBalanceStrategy

public class DefaultLoadBalanceStrategy
extends Object
implements LoadBalanceStrategy

默认的负载均衡策略,尽量使得负载在所有consumer之间平均分配,consumer之间分配的分区数差距不大于1

作者:
boyan(boyan@taobao.com)

嵌套类摘要
 
从接口 com.taobao.metamorphosis.client.consumer.LoadBalanceStrategy 继承的嵌套类/接口
LoadBalanceStrategy.Type
 
构造方法摘要
DefaultLoadBalanceStrategy()
           
 
方法摘要
 List<String> getPartitions(String topic, String consumerId, List<String> curConsumers, List<String> curPartitions)
          根据consumer id查找对应的分区列表
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

构造方法详细信息

DefaultLoadBalanceStrategy

public DefaultLoadBalanceStrategy()
方法详细信息

getPartitions

public List<String> getPartitions(String topic,
                                  String consumerId,
                                  List<String> curConsumers,
                                  List<String> curPartitions)
从接口 LoadBalanceStrategy 复制的描述
根据consumer id查找对应的分区列表

指定者:
接口 LoadBalanceStrategy 中的 getPartitions
参数:
topic - 分区topic
consumerId - consumerId
curConsumers - 当前所有的consumer列表
curPartitions - 当前的分区列表
返回:


Copyright © 2010–2013. All rights reserved.