Interface CommitLogObserver.OffsetCommitter
-
- All Superinterfaces:
java.io.Serializable
- All Known Subinterfaces:
CommitLogObserver.OnNextContext
- Enclosing interface:
- CommitLogObserver
public static interface CommitLogObserver.OffsetCommitter extends java.io.Serializable
Committer for manipulation with offset during consumption.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
commit(boolean success, java.lang.Throwable error)
Confirm processing of element.default void
confirm()
Successfully confirm the processing.default void
fail(java.lang.Throwable error)
Confirm failure of processing.default void
nack()
Nack processing (no error thrown, message can be immediately retried).
-
-
-
Method Detail
-
commit
void commit(boolean success, @Nullable java.lang.Throwable error)
Confirm processing of element.- Parameters:
success
- success/fail flagerror
- error that was thrown during processing
-
confirm
default void confirm()
Successfully confirm the processing.
-
fail
default void fail(java.lang.Throwable error)
Confirm failure of processing.- Parameters:
error
- error caught during processing
-
nack
default void nack()
Nack processing (no error thrown, message can be immediately retried).
-
-