diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java index b2db356c8a4..d3bb048f75d 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java @@ -234,7 +234,7 @@ private void handlePushReplyResult(PushReplyResult pushReplyResult, final Remoti } else { response.setCode(ResponseCode.SUCCESS); response.setRemark(null); - //set to zore to avoid client decoding exception + //set to zero to avoid client decoding exception responseHeader.setMsgId("0"); responseHeader.setQueueId(queueIdInt); responseHeader.setQueueOffset(0L);