类 com.taobao.metamorphosis.cluster.Broker
的使用

使用 Broker 的软件包

com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.cluster
com.taobao.metamorphosis.server
com.taobao.metamorphosis.utils

com.taobao.metamorphosis.client.consumer 中 Broker 的使用

返回 Broker 的 com.taobao.metamorphosis.client.consumer 中的方法

Broker

FetchRequest.getBroker()

参数类型为 Broker 的 com.taobao.metamorphosis.client.consumer 中的方法

void	FetchRequest.setBroker(Broker broker)

参数类型为 Broker 的 com.taobao.metamorphosis.client.consumer 中的构造方法

FetchRequest(Broker broker, long delay, TopicPartitionRegInfo topicPartitionRegInfo, int maxSize)

com.taobao.metamorphosis.cluster 中 Broker 的使用

返回 Broker 的 com.taobao.metamorphosis.cluster 中的方法

Broker	Cluster.getBrokerRandom(int id)
Broker	Cluster.getMasterBroker(int id)

返回变量类型为 Broker 的类型的 com.taobao.metamorphosis.cluster 中的方法

ConcurrentHashMap<Integer,Set<Broker>>	Cluster.getBrokers()
Set<Broker>	Cluster.remove(int id)

参数类型为 Broker 的 com.taobao.metamorphosis.cluster 中的方法

void	Cluster.addBroker(int id, Broker broker)

类型变量类型为 Broker 的 com.taobao.metamorphosis.cluster 中的方法参数

void	Cluster.addBroker(int id, Set<Broker> brokers)

com.taobao.metamorphosis.server 中 Broker 的使用

返回 Broker 的 com.taobao.metamorphosis.server 中的方法

Broker

BrokerZooKeeper.getBroker()

com.taobao.metamorphosis.utils 中 Broker 的使用

返回 Broker 的 com.taobao.metamorphosis.utils 中的方法

Broker

MetaZookeeper.getMasterBrokerById(int brokerId) 从zk查询master broker,不存在则返回null

返回变量类型为 Broker 的类型的 com.taobao.metamorphosis.utils 中的方法

Set<Broker>

MetaZookeeper.getBrokersById(int brokerId) 从zk查询一个id下的brokers,包含master和一个或多个slave