org.joyqueue.client.internal.consumer

接口 ConsumerIndexManager

所有超级接口:

LifeCycle, Online

所有已知实现类:

DefaultConsumerIndexManager, LocalConsumerIndexManager

public interface ConsumerIndexManager
extends LifeCycle

ConsumerIndexManager author: gaohaoxiang date: 2018/12/12

方法概要

限定符和类型	方法和说明
Map<String,org.joyqueue.exception.JoyQueueCode>	batchCommitReply(Map<String,List<ConsumeReply>> replyMap, String app, long timeout)
com.google.common.collect.Table<String,Short,FetchIndexData>	batchFetchIndex(Map<String,List<Short>> topicMap, String app, long timeout)
org.joyqueue.exception.JoyQueueCode	commitReply(String topic, List<ConsumeReply> replyList, String app, long timeout)
FetchIndexData	fetchIndex(String topic, String app, short partition, long timeout)
org.joyqueue.exception.JoyQueueCode	resetIndex(String topic, String app, short partition, long timeout)

从接口继承的方法 org.joyqueue.toolkit.lang.LifeCycle

start, stop

从接口继承的方法 org.joyqueue.toolkit.lang.Online

isStarted

方法详细资料

resetIndex

org.joyqueue.exception.JoyQueueCode resetIndex(String topic,
                                               String app,
                                               short partition,
                                               long timeout)

fetchIndex

FetchIndexData fetchIndex(String topic,
                          String app,
                          short partition,
                          long timeout)

commitReply

org.joyqueue.exception.JoyQueueCode commitReply(String topic,
                                                List<ConsumeReply> replyList,
                                                String app,
                                                long timeout)

batchFetchIndex

com.google.common.collect.Table<String,Short,FetchIndexData> batchFetchIndex(Map<String,List<Short>> topicMap,
                                                                             String app,
                                                                             long timeout)

batchCommitReply

Map<String,org.joyqueue.exception.JoyQueueCode> batchCommitReply(Map<String,List<ConsumeReply>> replyMap,
                                                                 String app,
                                                                 long timeout)