|
||||||||||
上一个类 下一个类 | 框架 无框架 | |||||||||
摘要: 嵌套 | 字段 | 构造方法 | 方法 | 详细信息: 字段 | 构造方法 | 方法 |
java.lang.Object com.taobao.metamorphosis.client.consumer.storage.ZkOffsetStorage
public class ZkOffsetStorage
基于zk的offset存储器
构造方法摘要 | |
---|---|
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 |
构造方法详细信息 |
---|
public ZkOffsetStorage(MetaZookeeper metaZookeeper, org.I0Itec.zkclient.ZkClient zkClient)
方法详细信息 |
---|
public void onZkClientChanged(org.I0Itec.zkclient.ZkClient newClient)
ZkClientChangedListener
复制的描述
ZkClientChangedListener
中的 onZkClientChanged
public void commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)
OffsetStorage
复制的描述
OffsetStorage
中的 commitOffset
group
- 消费者组名infoList
- 消费者订阅的消息分区信息列表public TopicPartitionRegInfo load(String topic, String group, Partition partition)
OffsetStorage
复制的描述
OffsetStorage
中的 load
public void close()
OffsetStorage
复制的描述
OffsetStorage
中的 close
public void initOffset(String topic, String group, Partition partition, long offset)
OffsetStorage
复制的描述
OffsetStorage
中的 initOffset
|
||||||||||
上一个类 下一个类 | 框架 无框架 | |||||||||
摘要: 嵌套 | 字段 | 构造方法 | 方法 | 详细信息: 字段 | 构造方法 | 方法 |