|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface OffsetManager
Stores and retrieves offsets for a Kafka consumer
Method Summary | |
---|---|
void |
deleteOffset(Partition partition)
Removes the offset for a given Partition . |
long |
getOffset(Partition partition)
Retrieves the offset for a given Partition |
void |
resetOffsets(java.util.Collection<Partition> partition)
Resets offsets for the given Partition s. |
void |
updateOffset(Partition partition,
long offset)
Updates the offset for a given Partition |
Methods inherited from interface java.io.Closeable |
---|
close |
Methods inherited from interface java.io.Flushable |
---|
flush |
Method Detail |
---|
void updateOffset(Partition partition, long offset)
Partition
partition
- the partition whose offset is to be updatedoffset
- the new offset valuelong getOffset(Partition partition)
Partition
partition
- the partition to be
void deleteOffset(Partition partition)
Partition
. Useful
for components that need to clean up after themselves.
partition
- for which to delete the JavaDocvoid resetOffsets(java.util.Collection<Partition> partition)
Partition
s. To be invoked when the values stored are invalid,
so a client cannot resume from that position. Implementations must decide on the best strategy to follow.
partition
- to reset
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |