com.taobao.metamorphosis.tools.query
接口 OffsetStorageQuery

所有已知实现类:
MysqlOffsetStorageQuery, ZkOffsetStorageQuery

public interface OffsetStorageQuery

offset的查询接口

作者:
pingwei

方法摘要
 List<String> getConsumerGroups()
           
 String getOffset(OffsetQueryDO queryDO)
          提供offset的查询,具体实现确定不同的查询数据源
 List<String> getPartitionsOf(String group, String topic)
           
 List<String> getTopicsExistOffset(String group)
           
 

方法详细信息

getOffset

String getOffset(OffsetQueryDO queryDO)
提供offset的查询,具体实现确定不同的查询数据源

参数:
queryDO -
返回:

getConsumerGroups

List<String> getConsumerGroups()

getTopicsExistOffset

List<String> getTopicsExistOffset(String group)

getPartitionsOf

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


Copyright © 2010–2013. All rights reserved.