类 com.taobao.metamorphosis.client.consumer.SubscriberInfo
的使用

使用 SubscriberInfo 的软件包

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

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

返回变量类型为 SubscriberInfo 的类型的 com.taobao.metamorphosis.client.consumer 中的方法

static ConcurrentHashMap<String,ConcurrentHashMap<String,SubscriberInfo>>

SubscribeInfoManagerAccessor.getGroupTopicSubcriberRegistry(SubscribeInfoManager subscribeInfoManager)

类型变量类型为 SubscriberInfo 的 com.taobao.metamorphosis.client.consumer 中的方法参数

void	ConsumerZooKeeper.registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy) 注册订阅者

类型变量类型为 SubscriberInfo 的 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 中 SubscriberInfo 的使用

类型变量类型为 SubscriberInfo 的 com.taobao.metamorphosis.metaslave 中的方法参数

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