类 com.taobao.metamorphosis.utils.MetaZookeeper.ZKGroupTopicDirs
的使用

使用 MetaZookeeper.ZKGroupTopicDirs 的软件包
com.taobao.metamorphosis.client.consumer   
 

com.taobao.metamorphosis.client.consumerMetaZookeeper.ZKGroupTopicDirs 的使用
 

参数类型为 MetaZookeeper.ZKGroupTopicDirscom.taobao.metamorphosis.client.consumer 中的方法
protected  void ConsumerZooKeeper.ZKLoadRebalanceListener.addPartitionTopicInfo(MetaZookeeper.ZKGroupTopicDirs topicDirs, String partitionString, String topic, String consumerThreadId)
           
protected  boolean ConsumerZooKeeper.ZKLoadRebalanceListener.ownPartition(MetaZookeeper.ZKGroupTopicDirs topicDirs, String partition, String topic, String consumerThreadId)
          添加分区的owner关系
 



Copyright © 2010–2013. All rights reserved.