public class ConsumerManager extends Object implements Serializable
Constructor and Description |
---|
ConsumerManager(FileIO fileIO,
Path tablePath) |
ConsumerManager(FileIO fileIO,
Path tablePath,
String branchName) |
Modifier and Type | Method and Description |
---|---|
Optional<Consumer> |
consumer(String consumerId) |
Map<String,Long> |
consumers()
Get all consumer.
|
void |
deleteConsumer(String consumerId) |
void |
expire(java.time.LocalDateTime expireDateTime) |
List<String> |
listAllIds()
List all consumer IDs.
|
OptionalLong |
minNextSnapshot() |
void |
resetConsumer(String consumerId,
Consumer consumer) |
public void deleteConsumer(String consumerId)
public OptionalLong minNextSnapshot()
public void expire(java.time.LocalDateTime expireDateTime)
public Map<String,Long> consumers() throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.