[INLONG-10988][Manager] Data preview filters data in tubes based on s…

…treamId
fuweng11 · Sep 2, 2024 · 2300584 · 2300584
1 parent 4de972e
commit 2300584
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQOperator.java b/...src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQOperator.java
@@ -71,6 +71,7 @@ public class TubeMQOperator {
     private static final String CREATE_USER = "&createUser=";
     private static final String CONF_MOD_AUTH_TOKEN = "&confModAuthToken=";
     private static final String MSG_COUNT = "&msgCount=";
+    private static final String FILTER_CONDS = "&filterConds=";
 
     private static final String QUERY_TOPIC_PATH = "/webapi.htm?method=admin_query_cluster_topic_view";
     private static final String QUERY_BROKER_PATH = "/webapi.htm?method=admin_query_broker_run_status";
@@ -288,7 +289,7 @@ public List<BriefMQMessage> queryLastMessage(TubeClusterInfo tubeCluster, String
             }
 
             String url = "http://" + brokerUrl + QUERY_MESSAGE_PATH + TOPIC_NAME + topicName + MSG_COUNT
-                    + request.getMessageCount();
+                    + request.getMessageCount() + FILTER_CONDS + streamInfo.getInlongStreamId();
             TubeMessageResponse response = HttpUtils.request(restTemplate, url, HttpMethod.GET,
                     null, new HttpHeaders(), TubeMessageResponse.class);
             if (response.getErrCode() != SUCCESS_CODE && response.getErrCode() != 200) {