kafka: fix incorrect rebalanceTimeoutMs for new members

Commelina · Apr 30, 2024 · 5f1c0c1 · 5f1c0c1
1 parent fb798f0
commit 5f1c0c1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hstream-kafka/HStream/Kafka/Group/Member.hs b/hstream-kafka/HStream/Kafka/Group/Member.hs
@@ -38,7 +38,7 @@ data Member
 newMemberFromReq :: K.RequestContext -> K.JoinGroupRequest -> T.Text -> [(T.Text, BS.ByteString)] -> IO Member
 newMemberFromReq reqCtx req memberId supportedProtocols = do
   sessionTimeoutMs <- IO.newIORef req.sessionTimeoutMs
-  rebalanceTimeoutMs <- IO.newIORef req.sessionTimeoutMs
+  rebalanceTimeoutMs <- IO.newIORef req.rebalanceTimeoutMs
 
   assignment <- IO.newIORef BS.empty