[INLONG-9870][Manager] Pulsar DataNode support to set compression type (

#9959) Co-authored-by: castorqin <[email protected]>
apache · Apr 11, 2024 · 90890c2 · 90890c2
1 parent 24bdfc1
commit 90890c2
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/...ager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeDTO.java b/...ager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeDTO.java
@@ -51,6 +51,9 @@ public class PulsarDataNodeDTO {
     @ApiModelProperty(value = "Pulsar token")
     private String token;
 
+    @ApiModelProperty("The compression format used for pulsar producer")
+    private String compressionType;
+
     /**
      * Get the dto instance from the request
      */

diff --git a/...ger-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeInfo.java b/...ger-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeInfo.java
@@ -44,6 +44,9 @@ public class PulsarDataNodeInfo extends DataNodeInfo {
     @ApiModelProperty("Pulsar admin url")
     private String adminUrl;
 
+    @ApiModelProperty("The compression format used for pulsar producer")
+    private String compressionType;
+
     public PulsarDataNodeInfo() {
         this.setType(DataNodeType.PULSAR);
     }

diff --git a/...-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeRequest.java b/...-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeRequest.java
@@ -43,6 +43,9 @@ public class PulsarDataNodeRequest extends DataNodeRequest {
     @ApiModelProperty("Pulsar admin url")
     private String adminUrl;
 
+    @ApiModelProperty("The compression format used for pulsar producer")
+    private String compressionType;
+
     public PulsarDataNodeRequest() {
         this.setType(DataNodeType.PULSAR);
     }