diff --git a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java index e732626c7f9..cf4932d9760 100644 --- a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java +++ b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java @@ -561,7 +561,7 @@ public StringBuilder getMessageSnapshot(String topicName, int partitionId, List messageList = DataConverterUtil.convertMessage(topicName, tmpMsgList); int i = 0; int startPos = Math.max(messageList.size() - msgCount, 0); - sb.append("{\"result\":true,\"errCode\":200,\"errMsg\":\"Success!\",\"dataSet\":["); + sb.append("{\"result\":true,\"errCode\":0,\"errMsg\":\"Success!\",\"dataSet\":["); for (; startPos < messageList.size(); startPos++) { if (i > 0) { sb.append(",");