com.taobao.metamorphosis.client.consumer.storage
类 ZkOffsetStorage

java.lang.Object
  继承者 com.taobao.metamorphosis.client.consumer.storage.ZkOffsetStorage
所有已实现的接口:
OffsetStorage, ZkClientChangedListener

public class ZkOffsetStorage
extends Object
implements OffsetStorage, ZkClientChangedListener

基于zk的offset存储器

作者:
boyan

构造方法摘要
ZkOffsetStorage(MetaZookeeper metaZookeeper, org.I0Itec.zkclient.ZkClient zkClient)
           
 
方法摘要
 void close()
          释放资源,meta客户端在关闭的时候会主动调用此方法
 void commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)
          保存offset到存储
 void initOffset(String topic, String group, Partition partition, long offset)
          初始化offset
 TopicPartitionRegInfo load(String topic, String group, Partition partition)
          加载一条消费者的订阅信息,如果不存在返回null
 void onZkClientChanged(org.I0Itec.zkclient.ZkClient newClient)
          当新的zkClient建立的时候
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

构造方法详细信息

ZkOffsetStorage

public ZkOffsetStorage(MetaZookeeper metaZookeeper,
                       org.I0Itec.zkclient.ZkClient zkClient)
方法详细信息

onZkClientChanged

public void onZkClientChanged(org.I0Itec.zkclient.ZkClient newClient)
从接口 ZkClientChangedListener 复制的描述
当新的zkClient建立的时候

指定者:
接口 ZkClientChangedListener 中的 onZkClientChanged

commitOffset

public void commitOffset(String group,
                         Collection<TopicPartitionRegInfo> infoList)
从接口 OffsetStorage 复制的描述
保存offset到存储

指定者:
接口 OffsetStorage 中的 commitOffset
参数:
group - 消费者组名
infoList - 消费者订阅的消息分区信息列表

load

public TopicPartitionRegInfo load(String topic,
                                  String group,
                                  Partition partition)
从接口 OffsetStorage 复制的描述
加载一条消费者的订阅信息,如果不存在返回null

指定者:
接口 OffsetStorage 中的 load
返回:

close

public void close()
从接口 OffsetStorage 复制的描述
释放资源,meta客户端在关闭的时候会主动调用此方法

指定者:
接口 OffsetStorage 中的 close

initOffset

public void initOffset(String topic,
                       String group,
                       Partition partition,
                       long offset)
从接口 OffsetStorage 复制的描述
初始化offset

指定者:
接口 OffsetStorage 中的 initOffset


Copyright © 2010–2013. All rights reserved.