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

使用 ConsumerZooKeeper 的软件包

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

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

返回 ConsumerZooKeeper 的 com.taobao.metamorphosis.client 中的方法

ConsumerZooKeeper	MetaMessageSessionFactory.getConsumerZooKeeper() 返回消费者和zk交互管理器
protected ConsumerZooKeeper	MetaMessageSessionFactory.initConsumerZooKeeper(RemotingClientWrapper remotingClientWrapper, org.I0Itec.zkclient.ZkClient zkClient2, ZkUtils.ZKConfig config)

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

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

SimpleMessageConsumer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, ConsumerConfig consumerConfig, ConsumerZooKeeper consumerZooKeeper, ProducerZooKeeper producerZooKeeper, SubscribeInfoManager subscribeInfoManager, RecoverManager recoverManager, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)

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

com.taobao.metamorphosis.metaslave 中 ConsumerZooKeeper 的子类

class

SlaveConsumerZooKeeper 为slave接收消息扩展的ConsumerZooKeeper

返回 ConsumerZooKeeper 的 com.taobao.metamorphosis.metaslave 中的方法

protected ConsumerZooKeeper

SlaveMetaMessageSessionFactory.initConsumerZooKeeper(RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig)