From 33fd330899145654b7c25eac36c0ceb3bbfe5aba Mon Sep 17 00:00:00 2001
From: zhouxiang <zhouxiang.zzx@alibaba-inc.com>
Date: Tue, 14 Jun 2022 14:47:29 +0800
Subject: [PATCH] Change PullMessageRequestHeader maxMsgNums to CFNullable

---
 .../common/protocol/header/PullMessageRequestHeader.java     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
index 5ac1899d5a..08790fc294 100644
--- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
+++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
@@ -35,8 +35,6 @@ public class PullMessageRequestHeader extends TopicQueueRequestHeader {
     @CFNotNull
     private Long queueOffset;
     @CFNotNull
-    private Integer maxMsgBytes;
-    @CFNotNull
     private Integer maxMsgNums;
     @CFNotNull
     private Integer sysFlag;
@@ -50,6 +48,9 @@ public class PullMessageRequestHeader extends TopicQueueRequestHeader {
     private Long subVersion;
     private String expressionType;
 
+    @CFNullable
+    private Integer maxMsgBytes;
+
     @Override
     public void checkFields() throws RemotingCommandException {
     }