(inlong) branch master updated: [INLONG-10415][Manager] Kafka source supports configuring wraptype (#10416)

[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 aa6ec09701 [INLONG-10415][Manager] Kafka source supports configuring 
wraptype (#10416)
aa6ec09701 is described below

commit aa6ec09701cd78310c14d2b619e7603f71fd6d8e
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Fri Jun 14 10:22:18 2024 +0800

    [INLONG-10415][Manager] Kafka source supports configuring wraptype (#10416)
---
 .../java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java  | 3 +--
 .../org/apache/inlong/manager/pojo/source/kafka/KafkaSourceDTO.java    | 3 +++
 .../apache/inlong/manager/pojo/source/kafka/KafkaSourceRequest.java    | 3 +++
 3 files changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
index 5c8afdbf5c..30c94fd17b 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
@@ -17,7 +17,6 @@
 
 package org.apache.inlong.manager.pojo.source.kafka;
 
-import org.apache.inlong.common.enums.MessageWrapType;
 import org.apache.inlong.manager.common.consts.SourceType;
 import org.apache.inlong.manager.common.util.CommonBeanUtils;
 import org.apache.inlong.manager.common.util.JsonTypeDefine;
@@ -97,7 +96,7 @@ public class KafkaSource extends StreamSource {
     private String dataEscapeChar;
 
     @ApiModelProperty(value = "The message body wrap  wrap type, including: 
RAW, INLONG_MSG_V0, INLONG_MSG_V1, etc")
-    private String wrapType = MessageWrapType.INLONG_MSG_V0.getName();
+    private String wrapType;
 
     public KafkaSource() {
         this.setSourceType(SourceType.KAFKA);
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceDTO.java
index 730f63f7b3..68325aeccf 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceDTO.java
@@ -103,6 +103,9 @@ public class KafkaSourceDTO {
     @ApiModelProperty(value = "Data field escape symbol")
     private String dataEscapeChar;
 
+    @ApiModelProperty(value = "The message body wrap  wrap type, including: 
RAW, INLONG_MSG_V0, INLONG_MSG_V1, etc")
+    private String wrapType;
+
     @ApiModelProperty("Properties for Kafka")
     private Map<String, Object> properties;
 
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceRequest.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceRequest.java
index 89da06d277..d8b4526825 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceRequest.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSourceRequest.java
@@ -89,6 +89,9 @@ public class KafkaSourceRequest extends SourceRequest {
     @ApiModelProperty(value = "Data field escape symbol")
     private String dataEscapeChar;
 
+    @ApiModelProperty(value = "The message body wrap  wrap type, including: 
RAW, INLONG_MSG_V0, INLONG_MSG_V1, etc")
+    private String wrapType;
+
     public KafkaSourceRequest() {
         this.setSourceType(SourceType.KAFKA);
     }