fix test case error

mxsm · Jun 27, 2024 · 8039dc2 · 8039dc2
1 parent 1dbe411
commit 8039dc2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/rocketmq-remoting/src/protocol/header/update_consumer_offset_header.rs b/rocketmq-remoting/src/protocol/header/update_consumer_offset_header.rs
@@ -266,7 +266,7 @@ mod tests {
         let header = <UpdateConsumerOffsetRequestHeader as FromMap>::from(&map).unwrap();
         assert_eq!(header.consumer_group, "");
         assert_eq!(header.topic, "");
-        assert_eq!(header.queue_id, Some(0));
-        assert_eq!(header.commit_offset, Some(0));
+        assert_eq!(header.queue_id, None);
+        assert_eq!(header.commit_offset, None);
     }
 }