hstream-kafka: add ResponseHeader (#1577)

hstreamdb · Aug 25, 2023 · e05bc09 · e05bc09
1 parent b2d6598
commit e05bc09
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/common/kafka/src/Kafka/Protocol/Message.hs b/common/kafka/src/Kafka/Protocol/Message.hs
@@ -1,5 +1,6 @@
 module Kafka.Protocol.Message
   ( RequestHeader (..)
+  , ResponseHeader (..)
   , ApiKey (..)
   ) where
 
@@ -19,3 +20,9 @@ data RequestHeader = RequestHeader
   } deriving (Show, Eq, Generic)
 
 instance Serializable RequestHeader
+
+newtype ResponseHeader = ResponseHeader
+  { responseCorrelationId :: Int32
+  } deriving (Show, Eq, Generic)
+
+instance Serializable ResponseHeader