diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java
new file mode 100644
index 00000000..325eee96
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java
@@ -0,0 +1,20 @@
+package com.hzya.frame.nifi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：Component18
+ * @Date：2025/5/19 15:39
+ * @Filename：Component18
+ */
+@Data
+public class Component18 {
+    private String id;
+    private String parentGroupId;
+    private String backPressureObjectThreshold;
+    private String backPressureDataSizeThreshold;
+    private String flowFileExpiration;
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java
new file mode 100644
index 00000000..32c1ecf0
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java
@@ -0,0 +1,23 @@
+package com.hzya.frame.nifi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：CreateConnection
+ * @Date：2025/5/19 15:35
+ * @Filename：CreateConnection
+ */
+@Data
+public class CreateConnection18 {
+    private String id;
+    private String sourceId;
+    private String sourceGroupId;
+    private String sourceType;
+    private String destinationId;
+    private String destinationGroupId;
+    private String destinationType;
+    private Revision18 revision;
+}
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java
new file mode 100644
index 00000000..1612e300
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java
@@ -0,0 +1,16 @@
+package com.hzya.frame.nifi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：Revision18
+ * @Date：2025/5/19 15:36
+ * @Filename：Revision18
+ */
+@Data
+public class Revision18 {
+    private String version;
+}
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java
new file mode 100644
index 00000000..06492b0e
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java
@@ -0,0 +1,20 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：Component17
+ * @Date：2025/5/19 11:58
+ * @Filename：Component17
+ */
+@Data
+public class Component18 {
+    private SourceOrDestination18 source;
+    private SourceOrDestination18 destination;
+    private List<String> selectedRelationships;
+}
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java
new file mode 100644
index 00000000..4be35d8e
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java
@@ -0,0 +1,17 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：CreateConnections
+ * @Date：2025/5/19 11:56
+ * @Filename：CreateConnections
+ */
+@Data
+public class CreateConnections18 {
+    private Revision18 revision;
+    private Component18 component;
+}
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java
new file mode 100644
index 00000000..dc387f19
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java
@@ -0,0 +1,16 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：Revision17
+ * @Date：2025/5/19 11:56
+ * @Filename：Revision17
+ */
+@Data
+public class Revision18 {
+    private String version;
+}
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java
new file mode 100644
index 00000000..17252bb0
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java
@@ -0,0 +1,18 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：SourceOrDestination
+ * @Date：2025/5/19 13:39
+ * @Filename：SourceOrDestination
+ */
+@Data
+public class SourceOrDestination18 {
+    private String id;
+    private String groupId;
+    private String type;
+}
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java
index 7d321a3f..cc0fb693 100644
--- a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java
@@ -4,6 +4,8 @@ import cn.hutool.core.util.StrUtil;
 import com.hzya.frame.nifi.client.NifiClient;
 import com.hzya.frame.nifi.model.joinbindparametercontexts.BindParameterContextsJoin11;
 import com.hzya.frame.nifi.model.joincontrollerenabled.EnOrDiControllerServices12;
+import com.hzya.frame.nifi.model.joincreateconnection.CreateConnection18;
+import com.hzya.frame.nifi.model.joincreateconnections.CreateConnections18;
 import com.hzya.frame.nifi.model.joincreatetemp.CreateTemplateJoin;
 import com.hzya.frame.nifi.model.joingetcontroller.ControllerService12;
 import com.hzya.frame.nifi.model.joinparametercontexts.ParameterContextsJoin;
@@ -242,4 +244,11 @@ public class NifiApiService {
     public ProcessorsInfo16 deleteProcessor(String processId, Map<String, String> queryParams) throws Exception {
         return client.delete(StrUtil.format("/processors/{}", processId), queryParams, ProcessorsInfo16.class);
     }
+
+    /**
+     * 建立连接关系
+     */
+    public CreateConnection18 createProcessorConnections(String processGroupsId, CreateConnections18 createConnections17) throws Exception {
+        return client.post(StrUtil.format("/process-groups/{}/connections", processGroupsId), createConnections17, CreateConnection18.class);
+    }
 }
\ No newline at end of file