Class LeaderFollowerPartitionStateModel.LeaderSessionIdChecker

  • Enclosing class:

    public static class LeaderFollowerPartitionStateModel.LeaderSessionIdChecker
    extends java.lang.Object
    A leader session id checker will be created for each consumer action; server checks whether the session id is still valid before processing the consumer action.
    • Constructor Summary

      Constructor Description
      LeaderSessionIdChecker​(long assignedSessionId, java.util.concurrent.atomic.AtomicLong latestSessionIdHandle)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean isSessionIdValid()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • LeaderSessionIdChecker

        public LeaderSessionIdChecker​(long assignedSessionId,
                                      java.util.concurrent.atomic.AtomicLong latestSessionIdHandle)
    • Method Detail

      • isSessionIdValid

        public boolean isSessionIdValid()