diff --git a/hstream-kafka/client/HStream/Kafka/Client/Core.hs b/hstream-kafka/client/HStream/Kafka/Client/Core.hs
index bbc234d9e..5bba3e71d 100644
--- 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
index 8c4f92056..e235f2090 100644
--- 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