merge upstream main

hstreamdb · Sep 22, 2023 · 050dcbe · 050dcbe
1 parent 7bf8cf3
commit 050dcbe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hstream-kafka/HStream/Kafka/Group/OffsetsStore.hs b/hstream-kafka/HStream/Kafka/Group/OffsetsStore.hs
@@ -44,4 +44,4 @@ mkCkpOffsetStorage client ckpStoreName = do
 instance OffsetStorage CkpOffsetStorage where
   commitOffsets CkpOffsetStorage{..} offsetsKey offsets = do
     unless (Map.null offsets) $ do
-      S.ckpStoreUpdateMultiLSNSync ckpStore (textToCBytes offsetsKey) offsets
+      S.ckpStoreUpdateMultiLSN ckpStore (textToCBytes offsetsKey) offsets