hstream-kafka-client: wip

hstreamdb · Sep 27, 2023 · 99770c0 · 99770c0
1 parent f3f421d
commit 99770c0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/hstream-kafka/client/HStream/Kafka/Client/Core.hs b/hstream-kafka/client/HStream/Kafka/Client/Core.hs
@@ -88,7 +88,7 @@ handleCreateTopic opts topicName numPartitions replicationFactor = do
                     , K.requestApiVersion    = 0
                     , K.requestCorrelationId = 1 -- FIXME
                     , K.requestClientId      = requestClientId
-                    , K.requesteTaggedFields = Right K.EmptyTaggedFields
+                    , K.requesteTaggedFields = Left K.Unsupported
                     }
       reqBody   = K.CreateTopicsRequestV0
                     (K.KaArray $ Just [topic])
@@ -110,7 +110,7 @@ handleDeleteTopic opts topicName = do
                     , K.requestApiVersion    = 0
                     , K.requestCorrelationId = 1 -- FIXME
                     , K.requestClientId      = requestClientId
-                    , K.requesteTaggedFields = Right K.EmptyTaggedFields
+                    , K.requesteTaggedFields = Left K.Unsupported
                     }
       reqBody   = K.DeleteTopicsRequestV0
                     (K.KaArray $ Just [T.pack topicName])

diff --git a/hstream-kafka/client/HStream/Kafka/Client/Network.hs b/hstream-kafka/client/HStream/Kafka/Client/Network.hs
@@ -71,6 +71,6 @@ sendAndRecv :: forall req resp header.
 sendAndRecv opts reqHeader reqBody = withSock opts $ \sock -> do
   let reqBs' = K.runPut reqHeader <> K.runPut @req reqBody
       reqLen = K.runPut @Int32 $ fromIntegral (BS.length reqBs')
-      reqBs  = reqLen <> reqBs
+      reqBs  = reqLen <> reqBs'
   NW.sendAll sock reqBs
   recvResp @resp sock