com.taobao.metamorphosis.tools.query
接口 OffsetStorageQuery
- 所有已知实现类:
- MysqlOffsetStorageQuery, ZkOffsetStorageQuery
public interface OffsetStorageQuery
offset的查询接口
- 作者:
- pingwei
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.