(inlong) branch master updated: [INLONG-10368][Manager] Data preview supports obtaining message attribute information (#10369)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new ce49ad9bc8 [INLONG-10368][Manager] Data preview supports obtaining 
message attribute information (#10369)
ce49ad9bc8 is described below

commit ce49ad9bc8b5ea08a51f251a0ad8621c67d7424a
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Thu Jun 6 19:02:59 2024 +0800

    [INLONG-10368][Manager] Data preview supports obtaining message attribute 
information (#10369)
---
 .../java/org/apache/inlong/manager/pojo/consume/BriefMQMessage.java    | 3 +++
 .../inlong/manager/service/message/InlongMsgDeserializeOperator.java   | 1 +
 2 files changed, 4 insertions(+)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/consume/BriefMQMessage.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/consume/BriefMQMessage.java
index d471c23865..6161684b43 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/consume/BriefMQMessage.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/consume/BriefMQMessage.java
@@ -52,6 +52,9 @@ public class BriefMQMessage {
     @ApiModelProperty(value = "Client ip")
     private String clientIp;
 
+    @ApiModelProperty(value = "Message attribute")
+    private String attribute;
+
     @ApiModelProperty(value = "Message header")
     private Map<String, String> headers;
 
diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/message/InlongMsgDeserializeOperator.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/message/InlongMsgDeserializeOperator.java
index d805ead216..b04931db0f 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/message/InlongMsgDeserializeOperator.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/message/InlongMsgDeserializeOperator.java
@@ -94,6 +94,7 @@ public class InlongMsgDeserializeOperator implements 
DeserializeOperator {
                             .dt(msgTime)
                             .clientIp(attrMap.get(CLIENT_IP))
                             .headers(headers)
+                            .attribute(attr)
                             .body(body)
                             .fieldList(streamFieldList)
                             .build();