[INLONG-9985][Manager] Support authentication params for pulsar source (

#9986)
apache · Apr 15, 2024 · 4ebe63f · 4ebe63f
1 parent b1de06b
commit 4ebe63f
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 2 deletions.
diff --git a/...-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java b/...-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java
@@ -81,8 +81,8 @@ public ExtractNode createExtractNode(StreamNode streamNodeInfo) {
                 primaryKey,
                 pulsarSource.getSubscription(),
                 scanStartupSubStartOffset,
-                "",
-                "");
+                pulsarSource.getClientAuthPluginClassName(),
+                pulsarSource.getClientAuthParams());
     }
 
     @Override

diff --git a/...manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSource.java b/...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/...ager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceDTO.java b/...ager-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/...-pojo/src/main/java/org/apache/inlong/manager/pojo/source/pulsar/PulsarSourceRequest.java b/...-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;