diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java index 85cbce9b6a9..c9c2a8090ce 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java @@ -190,7 +190,7 @@ public int hashCode() { prime * result + (int) (whichBrokerWhenConsumeSlowly ^ (whichBrokerWhenConsumeSlowly >>> 32)); result = prime * result + groupSysFlag; result = prime * result + consumeTimeoutMinute; - result = prime * result + subscriptionDataSet.hashCode(); + result = prime * result + ((subscriptionDataSet == null) ? 0 : subscriptionDataSet.hashCode()); result = prime * result + attributes.hashCode(); return result; }