Kafka SparseOffset: Fetch handler

hstreamdb · May 15, 2024 · a39d05c · a39d05c
1 parent 7501a1b
commit a39d05c
Show file tree

Hide file tree

Showing 5 changed files with 358 additions and 210 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)