Modifier and Type | Field and Description |
---|---|
static IRecordStarvationStrategy |
RecordStarvationStrategies.ALWAYS_RETRY
Keeps consuming records
|
static IRecordStarvationStrategy |
RecordStarvationStrategies.EARLY_ABORT
Aborts at first record starvation
|
Modifier and Type | Method and Description |
---|---|
ITopicStore.IResumeToken |
ILiveStream.subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler,
IRecordStarvationStrategy onStarve) |
Modifier and Type | Method and Description |
---|---|
ITopicStore.IResumeToken |
LiveStream.subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler,
IRecordStarvationStrategy onStarve) |
Modifier and Type | Class and Description |
---|---|
class |
RecordStarvationHandler |
Modifier and Type | Method and Description |
---|---|
ITopicStore.IResumeToken |
TopicSubscriber.subscribe(ITopicStore.IResumeToken index,
java.util.function.BiConsumer<byte[],byte[]> handler,
IRecordStarvationStrategy strat) |
Modifier and Type | Method and Description |
---|---|
ITopicStore.IResumeToken |
KafkaTopicSubscriber.subscribe(ITopicStore.IResumeToken index,
java.util.function.BiConsumer<byte[],byte[]> handler,
IRecordStarvationStrategy strat) |
Copyright © 2022. All Rights Reserved.