Пример использования NiFi REST API

{
  "permissions": {
    "canRead": true,
    "canWrite": true
  },
  "processGroupFlow": {
    "id": "4410f0eb-018c-1000-9096-472c6e6db150",
    "uri": "http://sov-test-1.ru-central1.internal:9090/nifi-api/flow/process-groups/4410f0eb-018c-1000-9096-472c6e6db150",
    "breadcrumb": {
      "id": "4410f0eb-018c-1000-9096-472c6e6db150",
      "permissions": {
        "canRead": true,
        "canWrite": true
      },
      "breadcrumb": {
        "id": "4410f0eb-018c-1000-9096-472c6e6db150",
        "name": "NiFi Flow"
      }
    },
    "flow": {
      "processGroups": [],
      "remoteProcessGroups": [],
      "processors": [],
      "inputPorts": [],
      "outputPorts": [],
      "connections": [],
      "labels": [],
      "funnels": []
    },
    "lastRefreshed": "19:32:09 UTC"
  }
}

$ curl -X POST \
  http://sov-test-1.ru-central1.internal:9090/nifi-api/process-groups/4410f0eb-018c-1000-9096-472c6e6db150/processors \
  -H 'Content-Type: application/json' \
  -d  '{ \
    "revision": { \
        "version": 0 \
    }, \
     "component": { \
        "parentGroupId": "4410f0eb-018c-1000-9096-472c6e6db150", \
        "position": { \
            "x": 200, \
            "y": 0 \
        }, \
        "name": "GenerateFlowFile", \
        "type": "org.apache.nifi.processors.standard.GenerateFlowFile", \
        "bundle": { \
            "group": "org.apache.nifi", \
            "artifact": "nifi-standard-nar", \
            "version": "1.20.0" \
        }, \
        "state": "STOPPED", \
        "config": { \
            "properties": { \
                "File Size": "0B", \
                "Batch Size": "1", \
                "Data Format": "Text", \
                "Unique FlowFiles": "false", \
                "generate-ff-custom-text": "my custom message", \
                "character-set": "UTF-8", \
                "mime-type": null \
            } \
        } \
    } \
}' |jq

$ curl -X POST \
  http://sov-test-1.ru-central1.internal:9090/nifi-api/process-groups/4410f0eb-018c-1000-9096-472c6e6db150/processors \
  -H 'Content-Type: application/json' \
  -d  '{ \
    "revision": { \
        "version": 0 \
    }, \
    "component": { \
        "parentGroupId": "4410f0eb-018c-1000-9096-472c6e6db150", \
        "position": { \
            "x": 200, \
            "y": 400 \
        }, \
        "name": "PublishKafka_2_6", \
        "type": "org.apache.nifi.processors.kafka.pubsub.PublishKafka_2_6", \
        "bundle": { \
        "group": "org.apache.nifi", \
        "artifact": "nifi-kafka-2-6-nar", \
        "version": "1.20.0" \
        }, \
        "state": "STOPPED", \
        "config": { \
            "properties": { \
                "bootstrap.servers": "sov-test-2.ru-central1.internal:9092", \
                "topic": "my_new_topic" \
            }, \
         "autoTerminatedRelationships":["success","failure"] \
         } \
    } \
}' |jq

{
  "revision": {
    "version": 1,
    "lastModifier": "anonymous"
  },
  "id": "5f46b4af-018c-1000-f339-ca645d27debf",
  "uri": "http://sov-test-1.ru-central1.internal:9090/nifi-api/processors/5f46b4af-018c-1000-f339-ca645d27debf",
  "position": {
    "x": 200,
    "y": 0
  },
  "permissions": {
    "canRead": true,
    "canWrite": true
  },
  "bulletins": [],
  "component": {
    "id": "5f46b4af-018c-1000-f339-ca645d27debf",
    "parentGroupId": "4410f0eb-018c-1000-9096-472c6e6db150",
    "position": {
      "x": 200,
      "y": 0
    },
    "name": "GenerateFlowFile",
    "type": "org.apache.nifi.processors.standard.GenerateFlowFile",
    "bundle": {
      "group": "org.apache.nifi",
      "artifact": "nifi-standard-nar",
      "version": "1.20.0"
    },
    "state": "STOPPED",
    "style": {},
    "relationships": [
      {
        "name": "success",
        "description": "",
        "autoTerminate": false,
        "retry": false
      }
    ],
    "supportsParallelProcessing": true,
    "supportsEventDriven": false,
    "supportsBatching": true,
    "supportsSensitiveDynamicProperties": false,
    "persistsState": false,
    "restricted": false,
    "deprecated": false,
    "executionNodeRestricted": false,
    "multipleVersionsAvailable": false,
    "inputRequirement": "INPUT_FORBIDDEN",
    "config": {
      "properties": {
        "File Size": "0B",
        "Batch Size": "1",
        "Data Format": "Text",
        "Unique FlowFiles": "false",
        "generate-ff-custom-text": "my custom message",
        "character-set": "UTF-8",
        "mime-type": null
      },
      "descriptors": {
        "File Size": {
          "name": "File Size",
          "displayName": "File Size",
          "description": "The size of the file that will be used",
          "defaultValue": "0B",
          "required": true,
          "sensitive": false,
          "dynamic": false,
          "supportsEl": false,
          "expressionLanguageScope": "Not Supported",
          "dependencies": []
        },
        "Batch Size": {
          "name": "Batch Size",
          "displayName": "Batch Size",
          "description": "The number of FlowFiles to be transferred in each invocation",
          "defaultValue": "1",
          "required": true,
          "sensitive": false,
          "dynamic": false,
          "supportsEl": false,
          "expressionLanguageScope": "Not Supported",
          "dependencies": []
        },
        "Data Format": {
          "name": "Data Format",
          "displayName": "Data Format",
          "description": "Specifies whether the data should be Text or Binary",
          "defaultValue": "Text",
          "allowableValues": [
            {
              "allowableValue": {
                "displayName": "Binary",
                "value": "Binary"
              },
              "canRead": true
            },
            {
              "allowableValue": {
                "displayName": "Text",
                "value": "Text"
              },
              "canRead": true
            }
          ],
          "required": true,
          "sensitive": false,
          "dynamic": false,
          "supportsEl": false,
          "expressionLanguageScope": "Not Supported",
          "dependencies": []
        },
        "Unique FlowFiles": {
          "name": "Unique FlowFiles",
          "displayName": "Unique FlowFiles",
          "description": "If true, each FlowFile that is generated will be unique. If false, a random value will be generated and all FlowFiles will get the same content but this offers much higher throughput",
          "defaultValue": "false",
          "allowableValues": [
            {
              "allowableValue": {
                "displayName": "true",
                "value": "true"
              },
              "canRead": true
            },
            {
              "allowableValue": {
                "displayName": "false",
                "value": "false"
              },
              "canRead": true
            }
          ],
          "required": true,
          "sensitive": false,
          "dynamic": false,
          "supportsEl": false,
          "expressionLanguageScope": "Not Supported",
          "dependencies": []
        },
        "generate-ff-custom-text": {
          "name": "generate-ff-custom-text",
          "displayName": "Custom Text",
          "description": "If Data Format is text and if Unique FlowFiles is false, then this custom text will be used as content of the generated FlowFiles and the File Size will be ignored. Finally, if Expression Language is used, evaluation will be performed only once per batch of generated FlowFiles",
          "required": false,
          "sensitive": false,
          "dynamic": false,
          "supportsEl": true,
          "expressionLanguageScope": "Variable Registry Only",
          "dependencies": []
        },
        "character-set": {
          "name": "character-set",
          "displayName": "Character Set",
          "description": "Specifies the character set to use when writing the bytes of Custom Text to a flow file.",
          "defaultValue": "UTF-8",
          "required": true,
          "sensitive": false,
          "dynamic": false,
          "supportsEl": false,
          "expressionLanguageScope": "Not Supported",
          "dependencies": []
        },
        "mime-type": {
          "name": "mime-type",
          "displayName": "Mime Type",
          "description": "Specifies the value to set for the \"mime.type\" attribute.",
          "required": false,
          "sensitive": false,
          "dynamic": false,
          "supportsEl": false,
          "expressionLanguageScope": "Not Supported",
          "dependencies": []
        }
      },
      "schedulingPeriod": "1 min",
      "schedulingStrategy": "TIMER_DRIVEN",
      "executionNode": "ALL",
      "penaltyDuration": "30 sec",
      "yieldDuration": "1 sec",
      "bulletinLevel": "WARN",
      "runDurationMillis": 0,
      "concurrentlySchedulableTaskCount": 1,
      "comments": "",
      "lossTolerant": false,
      "defaultConcurrentTasks": {
        "TIMER_DRIVEN": "1",
        "EVENT_DRIVEN": "0",
        "CRON_DRIVEN": "1"
      },
      "defaultSchedulingPeriod": {
        "TIMER_DRIVEN": "0 sec",
        "CRON_DRIVEN": "* * * * * ?"
      },
      "retryCount": 10,
      "retriedRelationships": [],
      "backoffMechanism": "PENALIZE_FLOWFILE",
      "maxBackoffPeriod": "10 mins"
    },
    "validationErrors": [
      "'Relationship success' is invalid because Relationship 'success' is not connected to any component and is not auto-terminated"
    ],
    "validationStatus": "INVALID",
    "extensionMissing": false
  },
  "inputRequirement": "INPUT_FORBIDDEN",
  "status": {
    "groupId": "4410f0eb-018c-1000-9096-472c6e6db150",
    "id": "5f46b4af-018c-1000-f339-ca645d27debf",
    "name": "GenerateFlowFile",
    "runStatus": "Invalid",
    "statsLastRefreshed": "18:25:18 UTC",
    "aggregateSnapshot": {
      "id": "5f46b4af-018c-1000-f339-ca645d27debf",
      "groupId": "4410f0eb-018c-1000-9096-472c6e6db150",
      "name": "GenerateFlowFile",
      "type": "GenerateFlowFile",
      "runStatus": "Invalid",
      "executionNode": "ALL",
      "bytesRead": 0,
      "bytesWritten": 0,
      "read": "0 bytes",
      "written": "0 bytes",
      "flowFilesIn": 0,
      "bytesIn": 0,
      "input": "0 (0 bytes)",
      "flowFilesOut": 0,
      "bytesOut": 0,
      "output": "0 (0 bytes)",
      "taskCount": 0,
      "tasksDurationNanos": 0,
      "tasks": "0",
      "tasksDuration": "00:00:00.000",
      "activeThreadCount": 0,
      "terminatedThreadCount": 0
    }
  },
  "operatePermissions": {
    "canRead": true,
    "canWrite": true
  }
}

$ curl -X POST \
  http://sov-test-1.ru-central1.internal:9090/nifi-api/process-groups/4410f0eb-018c-1000-9096-472c6e6db150/connections \
  -H 'Content-Type: application/json' \
  -d  '{ \
    "revision": { \
        "version": 0 \
    }, \
    "component": { \
        "parentGroupId": "4410f0eb-018c-1000-9096-472c6e6db150", \
        "source": { \
            "id": "632d5f0c-018c-1000-3d78-410a76f1f451", \
            "type": "PROCESSOR", \
            "groupId": "4410f0eb-018c-1000-9096-472c6e6db150", \
            "name": "GenerateFlowFile" \
        }, \
        "destination": { \
            "id": "632beead-018c-1000-cbec-e625a264e27a", \
            "type": "PROCESSOR", \
            "groupId": "4410f0eb-018c-1000-9096-472c6e6db150", \
            "name": "PublishKafka_2_6" \
        }, \
        "name": "Test connection", \
        "selectedRelationships": [ \
            "success" \
        ] \
        } \
}' |jq

{
  "revision": {
    "version": 1,
    "lastModifier": "anonymous"
  },
  "id": "6339c013-018c-1000-cabb-b497fd92db23",
  "uri": "http://sov-test-1.ru-central1.internal:9090/nifi-api/connections/6339c013-018c-1000-cabb-b497fd92db23",
  "permissions": {
    "canRead": true,
    "canWrite": true
  },
  "component": {
    "id": "6339c013-018c-1000-cabb-b497fd92db23",
    "parentGroupId": "4410f0eb-018c-1000-9096-472c6e6db150",
    "source": {
      "id": "632d5f0c-018c-1000-3d78-410a76f1f451",
      "type": "PROCESSOR",
      "groupId": "4410f0eb-018c-1000-9096-472c6e6db150",
      "name": "GenerateFlowFile",
      "running": false,
      "comments": ""
    },
    "destination": {
      "id": "632beead-018c-1000-cbec-e625a264e27a",
      "type": "PROCESSOR",
      "groupId": "4410f0eb-018c-1000-9096-472c6e6db150",
      "name": "PublishKafka_2_6",
      "running": false,
      "comments": ""
    },
    "name": "Test connection",
    "labelIndex": 1,
    "zIndex": 0,
    "selectedRelationships": [
      "success"
    ],
    "availableRelationships": [
      "success"
    ],
    "backPressureObjectThreshold": 10000,
    "backPressureDataSizeThreshold": "1 GB",
    "flowFileExpiration": "0 sec",
    "prioritizers": [],
    "bends": [],
    "loadBalanceStrategy": "DO_NOT_LOAD_BALANCE",
    "loadBalanceCompression": "DO_NOT_COMPRESS",
    "loadBalanceStatus": "LOAD_BALANCE_NOT_CONFIGURED"
  },
  "status": {
    "id": "6339c013-018c-1000-cabb-b497fd92db23",
    "groupId": "4410f0eb-018c-1000-9096-472c6e6db150",
    "name": "Test connection",
    "statsLastRefreshed": "12:49:38 UTC",
    "sourceId": "632d5f0c-018c-1000-3d78-410a76f1f451",
    "sourceName": "GenerateFlowFile",
    "destinationId": "632beead-018c-1000-cbec-e625a264e27a",
    "destinationName": "PublishKafka_2_6",
    "aggregateSnapshot": {
      "id": "6339c013-018c-1000-cabb-b497fd92db23",
      "groupId": "4410f0eb-018c-1000-9096-472c6e6db150",
      "name": "Test connection",
      "sourceName": "GenerateFlowFile",
      "destinationName": "PublishKafka_2_6",
      "flowFilesIn": 0,
      "bytesIn": 0,
      "input": "0 (0 bytes)",
      "flowFilesOut": 0,
      "bytesOut": 0,
      "output": "0 (0 bytes)",
      "flowFilesQueued": 0,
      "bytesQueued": 0,
      "queued": "0 (0 bytes)",
      "queuedSize": "0 bytes",
      "queuedCount": "0",
      "percentUseCount": 0,
      "percentUseBytes": 0,
      "flowFileAvailability": "ACTIVE_QUEUE_EMPTY"
    }
  },
  "bends": [],
  "labelIndex": 1,
  "zIndex": 0,
  "sourceId": "632d5f0c-018c-1000-3d78-410a76f1f451",
  "sourceGroupId": "4410f0eb-018c-1000-9096-472c6e6db150",
  "sourceType": "PROCESSOR",
  "destinationId": "632beead-018c-1000-cbec-e625a264e27a",
  "destinationGroupId": "4410f0eb-018c-1000-9096-472c6e6db150",
  "destinationType": "PROCESSOR"
}