(inlong) branch master updated: [INLONG-9985][Manager] Support authentication params for pulsar source (#9986)

[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 4ebe63fbc2 [INLONG-9985][Manager] Support authentication params for 
pulsar source (#9986)
4ebe63fbc2 is described below

commit 4ebe63fbc2da85859407b7610f0c250e74f43333
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Mon Apr 15 12:41:35 2024 +0800

    [INLONG-9985][Manager] Support authentication params for pulsar source 
(#9986)
---
 .../inlong/manager/pojo/sort/node/provider/PulsarProvider.java      | 4 ++--
 .../org/apache/inlong/manager/pojo/source/pulsar/PulsarSource.java  | 6 ++++++
 .../apache/inlong/manager/pojo/source/pulsar/PulsarSourceDTO.java   | 6 ++++++
 .../inlong/manager/pojo/source/pulsar/PulsarSourceRequest.java      | 6 ++++++
 4 files changed, 20 insertions(+), 2 deletions(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java
index 9ef0a1634a..a0fada67c1 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java
@@ -81,8 +81,8 @@ public class PulsarProvider implements ExtractNodeProvider {
                 primaryKey,
                 pulsarSource.getSubscription(),
                 scanStartupSubStartOffset,
-                "",
-                "");
+                pulsarSource.getClientAuthPluginClassName(),
+                pulsarSource.getClientAuthParams());
     }
 
     @Override
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSource.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSource.java
index 8c14d8118b..884100c988 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSource.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSource.java
@@ -88,6 +88,12 @@ public class PulsarSource extends StreamSource {
     @Builder.Default
     private String wrapType = MessageWrapType.INLONG_MSG_V0.getName();
 
+    @ApiModelProperty(value = "Client auth plugin class name")
+    private String clientAuthPluginClassName;
+
+    @ApiModelProperty(value = "Client auth params")
+    private String clientAuthParams;
+
     @ApiModelProperty("Reset subscription time")
     private Long resetTime;
 
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceDTO.java
index 6c0ba66208..2f9c9b1ab1 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceDTO.java
@@ -80,6 +80,12 @@ public class PulsarSourceDTO {
     @ApiModelProperty(value = "The message body wrap  wrap type, including: 
RAW, INLONG_MSG_V0, INLONG_MSG_V1, etc")
     private String wrapType;
 
+    @ApiModelProperty(value = "Client auth plugin class name")
+    private String clientAuthPluginClassName;
+
+    @ApiModelProperty(value = "Client auth params")
+    private String clientAuthParams;
+
     @ApiModelProperty("Reset subscription time")
     private Long resetTime;
 
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceRequest.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceRequest.java
index c9ebf258f0..0c6946bc6e 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceRequest.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceRequest.java
@@ -76,6 +76,12 @@ public class PulsarSourceRequest extends SourceRequest {
             + " Available options are earliest, latest, external-subscription, 
and specific-offsets.")
     private String scanStartupMode = "earliest";
 
+    @ApiModelProperty(value = "Client auth plugin class name")
+    private String clientAuthPluginClassName;
+
+    @ApiModelProperty(value = "Client auth params")
+    private String clientAuthParams;
+
     @ApiModelProperty("Reset subscription time")
     private Long resetTime;