接口 com.taobao.metamorphosis.client.consumer.FetchManager
的使用

使用 FetchManager 的软件包

com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.metaslave

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

实现 FetchManager 的 com.taobao.metamorphosis.client.consumer 中的类

class

SimpleFetchManager 消息抓取管理器的实现

类型参数类型为 FetchManager 的 com.taobao.metamorphosis.client.consumer 中的字段

protected ConcurrentHashMap<FetchManager,FutureTask<ConsumerZooKeeper.ZKLoadRebalanceListener>>

ConsumerZooKeeper.consumerLoadBalanceListeners

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

FetchManager

SimpleMessageConsumer.getFetchManager()

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

void	ConsumerZooKeeper.commitOffsets(FetchManager fetchManager)
ConsumerZooKeeper.ZKLoadRebalanceListener	ConsumerZooKeeper.getBrokerConnectionListener(FetchManager fetchManager)
void	ConsumerZooKeeper.registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy) 注册订阅者
void	ConsumerZooKeeper.unRegisterConsumer(FetchManager fetchManager) 取消注册consumer

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

ConsumerZooKeeper.ZKLoadRebalanceListener(FetchManager fetchManager, MetaZookeeper.ZKGroupDirs dirs, String consumerIdString, ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, LoadBalanceStrategy loadBalanceStrategy)

com.taobao.metamorphosis.metaslave 中 FetchManager 的使用

参数类型为 FetchManager 的 com.taobao.metamorphosis.metaslave 中的方法

void	SlaveConsumerZooKeeper.registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)