|
||||||||||
上一个类 下一个类 | 框架 无框架 | |||||||||
摘要: 嵌套 | 字段 | 构造方法 | 方法 | 详细信息: 字段 | 构造方法 | 方法 |
java.lang.Object com.taobao.metamorphosis.client.consumer.storage.LocalOffsetStorage
public class LocalOffsetStorage
本地offset存储,存储在磁盘,默认存储在$HOME/.meta_offsets文件中
构造方法摘要 | |
---|---|
LocalOffsetStorage()
|
|
LocalOffsetStorage(String filePath)
|
方法摘要 | |
---|---|
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 |
从类 java.lang.Object 继承的方法 |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
构造方法详细信息 |
---|
public LocalOffsetStorage() throws IOException
IOException
public LocalOffsetStorage(String filePath) throws IOException
IOException
方法详细信息 |
---|
public void close()
OffsetStorage
复制的描述
OffsetStorage
中的 close
public void commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)
OffsetStorage
复制的描述
OffsetStorage
中的 commitOffset
group
- 消费者组名infoList
- 消费者订阅的消息分区信息列表public void initOffset(String topic, String group, Partition partition, long offset)
OffsetStorage
复制的描述
OffsetStorage
中的 initOffset
public TopicPartitionRegInfo load(String topic, String group, Partition partition)
OffsetStorage
复制的描述
OffsetStorage
中的 load
|
||||||||||
上一个类 下一个类 | 框架 无框架 | |||||||||
摘要: 嵌套 | 字段 | 构造方法 | 方法 | 详细信息: 字段 | 构造方法 | 方法 |