Experimental SpareOffset 3: Fetch handler

hstreamdb · May 20, 2024 · 090ae86 · 090ae86
1 parent 2ed8a84
commit 090ae86
Show file tree

Hide file tree

Showing 5 changed files with 365 additions and 213 deletions.
diff --git a/hstream-kafka/HStream/Kafka/Common/FetchManager.hs b/hstream-kafka/HStream/Kafka/Common/FetchManager.hs
@@ -22,9 +22,9 @@ import qualified HStream.Kafka.Common.RecordFormat as K
 import qualified HStream.Store                     as S
 
 data FetchLogContext = FetchLogContext
-  { nextOffset :: Int64
+  { expectedOffset :: Int64
     -- ^ Expect next offset to be fetched
-  , remRecords :: Vector K.Record
+  , remRecords     :: Vector K.Record
     -- ^ Remaining records of the batch
   } deriving (Show)