tmp

hstreamdb · May 15, 2024 · 2af266a · 2af266a
1 parent 2ff833b
commit 2af266a
Showing 1 changed file with 17 additions and 6 deletions.
diff --git a/hstream-kafka/HStream/Kafka/Server/Handler.hsc b/hstream-kafka/HStream/Kafka/Server/Handler.hsc
@@ -13,10 +13,13 @@ import           HStream.Kafka.Server.Handler.Group
 import           HStream.Kafka.Server.Handler.Offset
 import           HStream.Kafka.Server.Handler.Produce
 import           HStream.Kafka.Server.Handler.Security
+import           HStream.Kafka.Server.Handler.SparseOffset.Consume
+import           HStream.Kafka.Server.Handler.SparseOffset.Offset
+import           HStream.Kafka.Server.Handler.SparseOffset.Produce
 import           HStream.Kafka.Server.Handler.Topic
-import           HStream.Kafka.Server.Types                (ServerContext (..))
-import qualified Kafka.Protocol.Message                    as K
-import qualified Kafka.Protocol.Service                    as K
+import           HStream.Kafka.Server.Types                        (ServerContext (..))
+import qualified Kafka.Protocol.Message                            as K
+import qualified Kafka.Protocol.Service                            as K
 
 -------------------------------------------------------------------------------
 
@@ -93,16 +96,24 @@ import qualified Kafka.Protocol.Service                    as K
 #cv_handler CreateAcls, 0, 0
 #cv_handler DeleteAcls, 0, 0
 
+-- SparseOffset
+#cv_handler ListOffsets, 0, 2, SparseOffset
+#cv_handler Produce, 0, 7, SparseOffset
+#cv_handler Fetch, 0, 6, SparseOffset
+
 handlers :: ServerContext -> [K.ServiceHandler]
 handlers sc =
   [ #mk_handler ApiVersions, 0, 3
-  , #mk_handler ListOffsets, 0, 2
+  -- , #mk_handler ListOffsets, 0, 2
+  , #mk_handler ListOffsets, 0, 2, SparseOffset
   , #mk_handler Metadata, 0, 5
     -- Write
-  , #mk_handler Produce, 0, 7
+  --, #mk_handler Produce, 0, 7
+  , #mk_handler Produce, 0, 7, SparseOffset
   , #mk_handler InitProducerId, 0, 0
     -- Read
-  , #mk_handler Fetch, 0, 6
+  --, #mk_handler Fetch, 0, 6
+  , #mk_handler Fetch, 0, 6, SparseOffset
 
   , #mk_handler FindCoordinator, 0, 1