diff --git a/hstream-kafka/HStream/Kafka/Group/Member.hs b/hstream-kafka/HStream/Kafka/Group/Member.hs
index d9165fc5e..23cc82d94 100644
--- 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