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

使用 MetaZookeeper 的软件包

com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.client.consumer.storage
com.taobao.metamorphosis.client.producer
com.taobao.metamorphosis.metaslave
com.taobao.metamorphosis.server
com.taobao.metamorphosis.tools.query

com.taobao.metamorphosis.client 中 MetaZookeeper 的使用

声明为 MetaZookeeper 的 com.taobao.metamorphosis.client 中的字段

protected MetaZookeeper

MetaMessageSessionFactory.metaZookeeper

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

声明为 MetaZookeeper 的 com.taobao.metamorphosis.client.consumer 中的字段

protected MetaZookeeper

ConsumerZooKeeper.metaZookeeper

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

ConsumerZooKeeper(MetaZookeeper metaZookeeper, RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig)

com.taobao.metamorphosis.client.consumer.storage 中 MetaZookeeper 的使用

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

ZkOffsetStorage(MetaZookeeper metaZookeeper, org.I0Itec.zkclient.ZkClient zkClient)

com.taobao.metamorphosis.client.producer 中 MetaZookeeper 的使用

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

ProducerZooKeeper(MetaZookeeper metaZookeeper, RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, MetaClientConfig metaClientConfig)

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

参数类型为 MetaZookeeper 的 com.taobao.metamorphosis.metaslave 中的构造方法

SlaveConsumerZooKeeper(MetaZookeeper metaZookeeper, RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig, int brokerId)

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

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

MetaZookeeper

BrokerZooKeeper.getMetaZookeeper()

com.taobao.metamorphosis.tools.query 中 MetaZookeeper 的使用

参数类型为 MetaZookeeper 的 com.taobao.metamorphosis.tools.query 中的构造方法

ZkOffsetStorageQuery(org.I0Itec.zkclient.ZkClient zkClient, MetaZookeeper metaZookeeper)