From 050dcbef3d406b17408499c76596239736d498a8 Mon Sep 17 00:00:00 2001 From: YangKian <1207783292@qq.com> Date: Fri, 22 Sep 2023 17:38:33 +0800 Subject: [PATCH] merge upstream main --- hstream-kafka/HStream/Kafka/Group/OffsetsStore.hs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hstream-kafka/HStream/Kafka/Group/OffsetsStore.hs b/hstream-kafka/HStream/Kafka/Group/OffsetsStore.hs index 0e228ade2..4cba63b37 100644 --- 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