|
Spring Integration Kafka Support | ||||||||
| 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 Partitions. |
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)
Partitions. 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
|
Spring Integration Kafka Support | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||