com.taobao.metamorphosis.client.consumer.storage
接口 OffsetStorage

所有已知实现类：

LocalOffsetStorage, MysqlOffsetStorage, SlaveOffsetStorage, TairOffsetStorage, ZkOffsetStorage

public interface OffsetStorage

Offset存储器接口

作者：

boyan

方法摘要

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

方法详细信息

commitOffset

void commitOffset(String group,
                  Collection<TopicPartitionRegInfo> infoList)

保存offset到存储

参数：

group - 消费者组名

infoList - 消费者订阅的消息分区信息列表

load

TopicPartitionRegInfo load(String topic,
                           String group,
                           Partition partition)

加载一条消费者的订阅信息，如果不存在返回null

参数：

topic -

group -

partiton -

返回：

close

void close()

释放资源，meta客户端在关闭的时候会主动调用此方法

initOffset

void initOffset(String topic,
                String group,
                Partition partition,
                long offset)

初始化offset

参数：

topic -

group -

partition -

offset -