From 90890c2dd40e50bdf0dae875e5648c8e4bd76af1 Mon Sep 17 00:00:00 2001 From: castor <58140421+castorqin@users.noreply.github.com> Date: Thu, 11 Apr 2024 11:54:16 +0800 Subject: [PATCH] [INLONG-9870][Manager] Pulsar DataNode support to set compression type (#9959) Co-authored-by: castorqin --- .../inlong/manager/pojo/node/pulsar/PulsarDataNodeDTO.java | 3 +++ .../inlong/manager/pojo/node/pulsar/PulsarDataNodeInfo.java | 3 +++ .../inlong/manager/pojo/node/pulsar/PulsarDataNodeRequest.java | 3 +++ 3 files changed, 9 insertions(+) diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeDTO.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeDTO.java index 351c29ab11e..fc66f267f62 100644 --- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeDTO.java +++ b/inlong-manager/manager-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/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeInfo.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeInfo.java index 8626a0cd55f..bd6176e9418 100644 --- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeInfo.java +++ b/inlong-manager/manager-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/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeRequest.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeRequest.java index 0693f03aa25..c77e30f3aba 100644 --- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/pulsar/PulsarDataNodeRequest.java +++ b/inlong-manager/manager-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); }