org.joyqueue.client.internal.consumer

接口 ConsumerIndexManager

所有超级接口:

LifeCycle, Online

所有已知实现类:

DefaultConsumerIndexManager, LocalConsumerIndexManager

public interface ConsumerIndexManager
extends LifeCycle

ConsumerIndexManager author: gaohaoxiang date: 2018/12/12

字段概要

字段

限定符和类型	字段和说明
static long	MAX_INDEX
static long	MIN_INDEX

方法概要

限定符和类型	方法和说明
Map<Short,org.joyqueue.exception.JoyQueueCode>	batchCommitIndex(String topic, String app, Map<Short,Long> indexes, long timeout)
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	commitIndex(String topic, String app, short partition, long index, 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

字段详细资料

MAX_INDEX

static final long MAX_INDEX

另请参阅:

常量字段值

MIN_INDEX

static final long MIN_INDEX

另请参阅:

常量字段值

方法详细资料

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)

commitIndex

org.joyqueue.exception.JoyQueueCode commitIndex(String topic,
                                                String app,
                                                short partition,
                                                long index,
                                                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)

batchCommitIndex

Map<Short,org.joyqueue.exception.JoyQueueCode> batchCommitIndex(String topic,
                                                                String app,
                                                                Map<Short,Long> indexes,
                                                                long timeout)