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)
从类 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
- 分区topicconsumerId
- consumerIdcurConsumers
- 当前所有的consumer列表curPartitions
- 当前的分区列表
- 返回:
Copyright © 2010–2013. All rights reserved.