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

java.lang.Object
  com.taobao.metamorphosis.client.consumer.storage.MysqlOffsetStorage

所有已实现的接口：

OffsetStorage

public class MysqlOffsetStorage
extends Object
implements OffsetStorage

基于mysql数据库的offset存储器

作者：

boyan

字段摘要

static String

DEFAULT_TABLE_NAME

构造方法摘要

MysqlOffsetStorage(DataSource dataSource)

方法摘要

void	close() 释放资源，meta客户端在关闭的时候会主动调用此方法
void	commitOffset(String group, Collection<TopicPartitionRegInfo> infoList) 保存offset到存储
String	getTableName() offset保存的表名
void	initOffset(String topic, String group, Partition partition, long offset) 初始化offset
TopicPartitionRegInfo	load(String topic, String group, Partition partition) 加载一条消费者的订阅信息，如果不存在返回null
void	setTableName(String tableName) 设置表名，默认为meta_topic_partiton_group_offset

从类 java.lang.Object 继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细信息

DEFAULT_TABLE_NAME

public static final String DEFAULT_TABLE_NAME

另请参见：

常量字段值

构造方法详细信息

MysqlOffsetStorage

public MysqlOffsetStorage(DataSource dataSource)

方法详细信息

getTableName

public String getTableName()

offset保存的表名

返回：

setTableName

public void setTableName(String tableName)

设置表名，默认为meta_topic_partiton_group_offset

参数：

tableName -

commitOffset

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

从接口 OffsetStorage 复制的描述

保存offset到存储

指定者：

接口 OffsetStorage 中的 commitOffset

参数：

group - 消费者组名

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

close

public void close()

从接口 OffsetStorage 复制的描述

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

指定者：

接口 OffsetStorage 中的 close

initOffset

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

从接口 OffsetStorage 复制的描述

初始化offset

指定者：

接口 OffsetStorage 中的 initOffset

load

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

从接口 OffsetStorage 复制的描述

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

指定者：

接口 OffsetStorage 中的 load

返回：