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 flag
        error - 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).