From ea890d4d10fb56c6e8dc1205d1aec07ed0a8bfb7 Mon Sep 17 00:00:00 2001 From: gosonzhang <4675739@qq.com> Date: Tue, 15 Aug 2023 10:13:27 +0800 Subject: [PATCH] [INLONG-8716][TubeMQ] set error code 0 when it works --- .../apache/inlong/tubemq/server/broker/BrokerServiceServer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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(",");