com.taobao.metamorphosis.tools.query
类 ZkOffsetStorageQuery

java.lang.Object
  com.taobao.metamorphosis.tools.query.ZkOffsetStorageQuery

所有已实现的接口：

OffsetStorageQuery

public class ZkOffsetStorageQuery
extends Object
implements OffsetStorageQuery

从zk中查询client端的offset数据

作者：

pingwei

构造方法摘要

ZkOffsetStorageQuery(org.I0Itec.zkclient.ZkClient zkClient, MetaZookeeper metaZookeeper)

方法摘要

List<String>	getConsumerGroups()
String	getOffset(OffsetQueryDO queryDO) 提供offset的查询，具体实现确定不同的查询数据源
List<String>	getPartitionsOf(String group, String topic)
List<String>	getTopicsExistOffset(String group)
static long	parseOffsetAsLong(String offsetString)

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

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

构造方法详细信息

ZkOffsetStorageQuery

public ZkOffsetStorageQuery(org.I0Itec.zkclient.ZkClient zkClient,
                            MetaZookeeper metaZookeeper)

方法详细信息

getOffset

public String getOffset(OffsetQueryDO queryDO)

从接口 OffsetStorageQuery 复制的描述

提供offset的查询，具体实现确定不同的查询数据源

指定者：

接口 OffsetStorageQuery 中的 getOffset

返回：

parseOffsetAsLong

public static long parseOffsetAsLong(String offsetString)

getConsumerGroups

public List<String> getConsumerGroups()

指定者：

接口 OffsetStorageQuery 中的 getConsumerGroups

getTopicsExistOffset

public List<String> getTopicsExistOffset(String group)

指定者：

接口 OffsetStorageQuery 中的 getTopicsExistOffset

getPartitionsOf

public List<String> getPartitionsOf(String group,
                                    String topic)

指定者：

接口 OffsetStorageQuery 中的 getPartitionsOf