Created
March 29, 2021 03:52
-
-
Save asdaraujo/cf8b05c7121e9f10c1b75d608651539e to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8" standalone="yes"?><template encoding-version="1.3"> | |
<description/> | |
<groupId>7ba01444-0178-1000-0000-000065162889</groupId> | |
<name>collect-cloud-data-gcp</name> | |
<snippet> | |
<controllerServices> | |
<id>83014ebc-1df0-37b8-0000-000000000000</id> | |
<parentGroupId>c51c7c51-9f9b-3235-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-gcp-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<comments/> | |
<descriptors> | |
<entry> | |
<key>application-default-credentials</key> | |
<value> | |
<name>application-default-credentials</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compute-engine-credentials</key> | |
<value> | |
<name>compute-engine-credentials</name> | |
</value> | |
</entry> | |
<entry> | |
<key>service-account-json-file</key> | |
<value> | |
<name>service-account-json-file</name> | |
</value> | |
</entry> | |
<entry> | |
<key>service-account-json</key> | |
<value> | |
<name>service-account-json</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>GCPCredentialsControllerService</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>application-default-credentials</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>compute-engine-credentials</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>service-account-json-file</key> | |
</entry> | |
<entry> | |
<key>service-account-json</key> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.processors.gcp.credentials.service.GCPCredentialsControllerService</type> | |
</controllerServices> | |
<controllerServices> | |
<id>af153d08-e961-36c3-0000-000000000000</id> | |
<parentGroupId>c51c7c51-9f9b-3235-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-ssl-context-service-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<comments/> | |
<descriptors> | |
<entry> | |
<key>Keystore Filename</key> | |
<value> | |
<name>Keystore Filename</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Keystore Password</key> | |
<value> | |
<name>Keystore Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>key-password</key> | |
<value> | |
<name>key-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Keystore Type</key> | |
<value> | |
<name>Keystore Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Truststore Filename</key> | |
<value> | |
<name>Truststore Filename</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Truststore Password</key> | |
<value> | |
<name>Truststore Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Truststore Type</key> | |
<value> | |
<name>Truststore Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>SSL Protocol</key> | |
<value> | |
<name>SSL Protocol</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>Default NiFi SSL Context Service</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Keystore Filename</key> | |
<value>/var/lib/nifi/cm-auto-host_keystore.jks</value> | |
</entry> | |
<entry> | |
<key>Keystore Password</key> | |
</entry> | |
<entry> | |
<key>key-password</key> | |
</entry> | |
<entry> | |
<key>Keystore Type</key> | |
<value>JKS</value> | |
</entry> | |
<entry> | |
<key>Truststore Filename</key> | |
<value>/var/lib/nifi/cm-auto-in_cluster_truststore.jks</value> | |
</entry> | |
<entry> | |
<key>Truststore Password</key> | |
</entry> | |
<entry> | |
<key>Truststore Type</key> | |
<value>JKS</value> | |
</entry> | |
<entry> | |
<key>SSL Protocol</key> | |
<value>TLS</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.ssl.StandardRestrictedSSLContextService</type> | |
</controllerServices> | |
<processGroups> | |
<id>9fb3d900-7d1d-3a42-0000-000000000000</id> | |
<parentGroupId>c51c7c51-9f9b-3235-0000-000000000000</parentGroupId> | |
<position> | |
<x>520.0552549932493</x> | |
<y>4.979555757510525</y> | |
</position> | |
<comments/> | |
<contents> | |
<connections> | |
<id>1e6a5abf-17ea-3fcc-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>fbdecec1-0a57-3eb8-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>merged</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>29204737-d53f-3b6f-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>1f032945-c808-338d-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>2aa3a0fa-8ce0-3a0c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>bb66ff1d-c14c-30eb-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>3e5c1593-5bc5-3218-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>2aa3a0fa-8ce0-3a0c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>b909152c-e7fd-34b3-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>3fc7307d-e896-38d2-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>2aa3a0fa-8ce0-3a0c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>96262a7d-af2a-3054-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>3ffa4de6-c293-32cd-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>2aa3a0fa-8ce0-3a0c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>441a1c87-3f8e-3fa4-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>5ee7ab81-1757-306d-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>242831a8-f441-3492-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>fbdecec1-0a57-3eb8-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>b0450518-fe99-302b-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>29204737-d53f-3b6f-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_INACTIVE</loadBalanceStatus> | |
<loadBalanceStrategy>SINGLE_NODE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>experimental</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>2aa3a0fa-8ce0-3a0c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>f1c56e42-894b-3ed9-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>422c612d-9ffc-3086-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>242831a8-f441-3492-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>f340a4f6-55e8-3ec0-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>2aa3a0fa-8ce0-3a0c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>9fb3d900-7d1d-3a42-0000-000000000000</groupId> | |
<id>f9a997be-7699-3a4a-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<controllerServices> | |
<id>3ebc9ce6-f1b8-38e1-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<comments/> | |
<descriptors> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>csv-reader-csv-parser</key> | |
<value> | |
<name>csv-reader-csv-parser</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value> | |
<name>CSV Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value> | |
<name>Value Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Skip Header Line</key> | |
<value> | |
<name>Skip Header Line</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ignore-csv-header</key> | |
<value> | |
<name>ignore-csv-header</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value> | |
<name>Quote Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value> | |
<name>Escape Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
<value> | |
<name>Comment Marker</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
<value> | |
<name>Null String</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value> | |
<name>Trim Fields</name> | |
</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value> | |
<name>csvutils-character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>CSVReader</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>infer-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>csv-reader-csv-parser</key> | |
<value>commons-csv</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value>custom</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value>,</value> | |
</entry> | |
<entry> | |
<key>Skip Header Line</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>ignore-csv-header</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value>"</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value>\</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.csv.CSVReader</type> | |
</controllerServices> | |
<controllerServices> | |
<id>ab79f3a3-6f9e-3851-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<comments/> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService> | |
<name>schema-cache</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value> | |
<name>schema-protocol-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value> | |
<name>CSV Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value> | |
<name>Value Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Header Line</key> | |
<value> | |
<name>Include Header Line</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value> | |
<name>Quote Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value> | |
<name>Escape Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
<value> | |
<name>Comment Marker</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
<value> | |
<name>Null String</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value> | |
<name>Trim Fields</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Mode</key> | |
<value> | |
<name>Quote Mode</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Record Separator</key> | |
<value> | |
<name>Record Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Trailing Delimiter</key> | |
<value> | |
<name>Include Trailing Delimiter</name> | |
</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value> | |
<name>csvutils-character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>CSVRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value>no-schema</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>inherit-record-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value>custom</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value>,</value> | |
</entry> | |
<entry> | |
<key>Include Header Line</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value>"</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value>\</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Quote Mode</key> | |
<value>MINIMAL</value> | |
</entry> | |
<entry> | |
<key>Record Separator</key> | |
<value>\n</value> | |
</entry> | |
<entry> | |
<key>Include Trailing Delimiter</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.csv.CSVRecordSetWriter</type> | |
</controllerServices> | |
<controllerServices> | |
<id>f0be01f1-3b04-333b-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<comments/> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService> | |
<name>schema-cache</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value> | |
<name>schema-protocol-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value> | |
<name>CSV Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value> | |
<name>Value Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Header Line</key> | |
<value> | |
<name>Include Header Line</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value> | |
<name>Quote Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value> | |
<name>Escape Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
<value> | |
<name>Comment Marker</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
<value> | |
<name>Null String</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value> | |
<name>Trim Fields</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Mode</key> | |
<value> | |
<name>Quote Mode</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Record Separator</key> | |
<value> | |
<name>Record Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Trailing Delimiter</key> | |
<value> | |
<name>Include Trailing Delimiter</name> | |
</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value> | |
<name>csvutils-character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>CSVRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value>no-schema</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>inherit-record-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value>custom</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value>,</value> | |
</entry> | |
<entry> | |
<key>Include Header Line</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value>"</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value>\</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Quote Mode</key> | |
<value>MINIMAL</value> | |
</entry> | |
<entry> | |
<key>Record Separator</key> | |
<value>\n</value> | |
</entry> | |
<entry> | |
<key>Include Trailing Delimiter</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.csv.CSVRecordSetWriter</type> | |
</controllerServices> | |
<funnels> | |
<id>422c612d-9ffc-3086-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>2304.0</x> | |
<y>1136.0</y> | |
</position> | |
</funnels> | |
<processors> | |
<id>242831a8-f441-3492-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>1672.0</x> | |
<y>1096.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-gcp-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>GCP Credentials Provider Service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.gcp.credentials.service.GCPCredentialsService</identifiesControllerService> | |
<name>GCP Credentials Provider Service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-project-id</key> | |
<value> | |
<name>gcp-project-id</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-retry-count</key> | |
<value> | |
<name>gcp-retry-count</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-host</key> | |
<value> | |
<name>gcp-proxy-host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-port</key> | |
<value> | |
<name>gcp-proxy-port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-name</key> | |
<value> | |
<name>gcp-proxy-user-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-password</key> | |
<value> | |
<name>gcp-proxy-user-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-bucket</key> | |
<value> | |
<name>gcs-bucket</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-key</key> | |
<value> | |
<name>gcs-key</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-content-type</key> | |
<value> | |
<name>gcs-content-type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-object-md5</key> | |
<value> | |
<name>gcs-object-md5</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-object-crc32c</key> | |
<value> | |
<name>gcs-object-crc32c</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-object-acl</key> | |
<value> | |
<name>gcs-object-acl</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-server-side-encryption-key</key> | |
<value> | |
<name>gcs-server-side-encryption-key</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-overwrite-object</key> | |
<value> | |
<name>gcs-overwrite-object</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-content-disposition-type</key> | |
<value> | |
<name>gcs-content-disposition-type</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>GCP Credentials Provider Service</key> | |
<value>83014ebc-1df0-37b8-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>gcp-project-id</key> | |
</entry> | |
<entry> | |
<key>gcp-retry-count</key> | |
<value>6</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-host</key> | |
</entry> | |
<entry> | |
<key>gcp-proxy-port</key> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-name</key> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-password</key> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>gcs-bucket</key> | |
<value>#{gcs_bucket}</value> | |
</entry> | |
<entry> | |
<key>gcs-key</key> | |
<value>enriched/${filename}</value> | |
</entry> | |
<entry> | |
<key>gcs-content-type</key> | |
<value>${mime.type}</value> | |
</entry> | |
<entry> | |
<key>gcs-object-md5</key> | |
</entry> | |
<entry> | |
<key>gcs-object-crc32c</key> | |
</entry> | |
<entry> | |
<key>gcs-object-acl</key> | |
</entry> | |
<entry> | |
<key>gcs-server-side-encryption-key</key> | |
</entry> | |
<entry> | |
<key>gcs-overwrite-object</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>gcs-content-disposition-type</key> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PutGCSObject</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.gcp.storage.PutGCSObject</type> | |
</processors> | |
<processors> | |
<id>29204737-d53f-3b6f-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>1056.0</x> | |
<y>816.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>merge-strategy</key> | |
<value> | |
<name>merge-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>correlation-attribute-name</key> | |
<value> | |
<name>correlation-attribute-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value> | |
<name>Attribute Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>min-records</key> | |
<value> | |
<name>min-records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-records</key> | |
<value> | |
<name>max-records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>min-bin-size</key> | |
<value> | |
<name>min-bin-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-bin-size</key> | |
<value> | |
<name>max-bin-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-bin-age</key> | |
<value> | |
<name>max-bin-age</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.bin.count</key> | |
<value> | |
<name>max.bin.count</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>3ebc9ce6-f1b8-38e1-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>ab79f3a3-6f9e-3851-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>merge-strategy</key> | |
<value>Bin-Packing Algorithm</value> | |
</entry> | |
<entry> | |
<key>correlation-attribute-name</key> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value>Keep All Unique Attributes</value> | |
</entry> | |
<entry> | |
<key>min-records</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>max-records</key> | |
<value>10000</value> | |
</entry> | |
<entry> | |
<key>min-bin-size</key> | |
<value>0 B</value> | |
</entry> | |
<entry> | |
<key>max-bin-size</key> | |
</entry> | |
<entry> | |
<key>max-bin-age</key> | |
</entry> | |
<entry> | |
<key>max.bin.count</key> | |
<value>3</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>5 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Merge Records</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>merged</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.MergeRecord</type> | |
</processors> | |
<processors> | |
<id>2aa3a0fa-8ce0-3a0c-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>1056.0</x> | |
<y>1096.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value> | |
<name>include-zero-record-flowfiles</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cache-schema</key> | |
<value> | |
<name>cache-schema</name> | |
</value> | |
</entry> | |
<entry> | |
<key>experimental</key> | |
<value> | |
<name>experimental</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>3ebc9ce6-f1b8-38e1-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>ab79f3a3-6f9e-3851-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>cache-schema</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>experimental</key> | |
<value>Select *, 'beta_engine' as Status | |
from FLOWFILE | |
where part_no = 'a42CLDR' | |
and factory_no = 5</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Filtering and Enrichment</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>experimental</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.QueryRecord</type> | |
</processors> | |
<processors> | |
<id>441a1c87-3f8e-3fa4-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>440.0</x> | |
<y>1104.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value> | |
<name>topic_type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value> | |
<name>honor-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value> | |
<name>group.id</name> | |
</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value> | |
<name>auto.offset.reset</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
<value> | |
<name>header-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value> | |
<name>max.poll.records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value> | |
<name>max-uncommit-offset-wait</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value> | |
<name>Communications Timeout</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-3</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value>names</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>3ebc9ce6-f1b8-38e1-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>f0be01f1-3b04-333b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value>Factory-3-Group</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value>earliest</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value>10000</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value>1 secs</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value>60 secs</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 3 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>parse.failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>96262a7d-af2a-3054-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>440.0</x> | |
<y>960.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value> | |
<name>topic_type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value> | |
<name>honor-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value> | |
<name>group.id</name> | |
</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value> | |
<name>auto.offset.reset</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
<value> | |
<name>header-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value> | |
<name>max.poll.records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value> | |
<name>max-uncommit-offset-wait</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value> | |
<name>Communications Timeout</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-2</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value>names</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>3ebc9ce6-f1b8-38e1-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>f0be01f1-3b04-333b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value>Factory-2-Group</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value>earliest</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value>10000</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value>1 secs</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value>60 secs</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 2 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>parse.failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>b909152c-e7fd-34b3-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>440.0</x> | |
<y>808.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value> | |
<name>topic_type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value> | |
<name>honor-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value> | |
<name>group.id</name> | |
</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value> | |
<name>auto.offset.reset</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
<value> | |
<name>header-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value> | |
<name>max.poll.records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value> | |
<name>max-uncommit-offset-wait</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value> | |
<name>Communications Timeout</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-1</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value>names</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>3ebc9ce6-f1b8-38e1-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>f0be01f1-3b04-333b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value>Factory-1-Group</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value>earliest</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value>10000</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value>20 secs</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value>60 secs</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 1 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>parse.failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>bb66ff1d-c14c-30eb-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>440.0</x> | |
<y>1408.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value> | |
<name>topic_type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value> | |
<name>honor-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value> | |
<name>group.id</name> | |
</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value> | |
<name>auto.offset.reset</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
<value> | |
<name>header-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value> | |
<name>max.poll.records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value> | |
<name>max-uncommit-offset-wait</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value> | |
<name>Communications Timeout</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-5</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value>names</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>3ebc9ce6-f1b8-38e1-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>f0be01f1-3b04-333b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value>Factory-5-Group</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value>earliest</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value>10000</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value>1 secs</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value>60 secs</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 5 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>parse.failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>f9a997be-7699-3a4a-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>440.0</x> | |
<y>1256.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value> | |
<name>topic_type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value> | |
<name>honor-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value> | |
<name>group.id</name> | |
</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value> | |
<name>auto.offset.reset</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
<value> | |
<name>header-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value> | |
<name>max.poll.records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value> | |
<name>max-uncommit-offset-wait</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value> | |
<name>Communications Timeout</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-4</value> | |
</entry> | |
<entry> | |
<key>topic_type</key> | |
<value>names</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>3ebc9ce6-f1b8-38e1-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>f0be01f1-3b04-333b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>honor-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>group.id</key> | |
<value>Factory-4-Group</value> | |
</entry> | |
<entry> | |
<key>auto.offset.reset</key> | |
<value>earliest</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>header-name-regex</key> | |
</entry> | |
<entry> | |
<key>max.poll.records</key> | |
<value>10000</value> | |
</entry> | |
<entry> | |
<key>max-uncommit-offset-wait</key> | |
<value>1 secs</value> | |
</entry> | |
<entry> | |
<key>Communications Timeout</key> | |
<value>60 secs</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 4 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>parse.failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>fbdecec1-0a57-3eb8-0000-000000000000</id> | |
<parentGroupId>9fb3d900-7d1d-3a42-0000-000000000000</parentGroupId> | |
<position> | |
<x>1672.0</x> | |
<y>816.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-update-attribute-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Delete Attributes Expression</key> | |
<value> | |
<name>Delete Attributes Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Store State</key> | |
<value> | |
<name>Store State</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Stateful Variables Initial Value</key> | |
<value> | |
<name>Stateful Variables Initial Value</name> | |
</value> | |
</entry> | |
<entry> | |
<key>canonical-value-lookup-cache-size</key> | |
<value> | |
<name>canonical-value-lookup-cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>filename</key> | |
<value> | |
<name>filename</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Delete Attributes Expression</key> | |
</entry> | |
<entry> | |
<key>Store State</key> | |
<value>Do not store state</value> | |
</entry> | |
<entry> | |
<key>Stateful Variables Initial Value</key> | |
</entry> | |
<entry> | |
<key>canonical-value-lookup-cache-size</key> | |
<value>100</value> | |
</entry> | |
<entry> | |
<key>filename</key> | |
<value>experimental_engines.csv</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Update Filename</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
</processors> | |
</contents> | |
<name>Kafka Ingest</name> | |
<variables/> | |
</processGroups> | |
<processGroups> | |
<id>c055110a-0f5f-3937-0000-000000000000</id> | |
<parentGroupId>c51c7c51-9f9b-3235-0000-000000000000</parentGroupId> | |
<position> | |
<x>0.0</x> | |
<y>0.0</y> | |
</position> | |
<comments/> | |
<contents> | |
<connections> | |
<id>53dc0296-c41f-312e-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>29ff53b7-3a95-359c-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>d44ee007-d912-37ad-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>770c3f91-5851-355a-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>29ff53b7-3a95-359c-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>c57a0f06-6da3-341f-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>7a607151-59ff-3365-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>7ac0e741-2825-3b31-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>factory-4</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>95cf841a-8352-3c3c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>7b1f4cc6-7255-3f3f-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>3d15fd77-5c3b-3a02-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>9e3269b8-4033-3080-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>909f833c-35fe-3966-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>b9d3a8e6-3452-3740-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>factory-5</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>95cf841a-8352-3c3c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>97fc27aa-ee15-3399-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>c57a0f06-6da3-341f-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>factory-3</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>95cf841a-8352-3c3c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>a1eb596d-c4a8-339b-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>29ff53b7-3a95-359c-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>b9d3a8e6-3452-3740-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>ba58b3f5-e61f-3583-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>9c431f45-e5a1-34a1-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>factory-2</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>95cf841a-8352-3c3c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>cc4254ca-e43e-3aea-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>95cf841a-8352-3c3c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>3d15fd77-5c3b-3a02-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>cfed4e47-0cd0-3b18-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>d44ee007-d912-37ad-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>factory-1</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>95cf841a-8352-3c3c-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>ed508a89-03a5-3681-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>29ff53b7-3a95-359c-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>9c431f45-e5a1-34a1-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>ee50a5ce-bd83-3982-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>29ff53b7-3a95-359c-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute/> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name/> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>c055110a-0f5f-3937-0000-000000000000</groupId> | |
<id>7ac0e741-2825-3b31-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<controllerServices> | |
<id>065f16ee-13e5-347b-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<comments/> | |
<descriptors> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>csv-reader-csv-parser</key> | |
<value> | |
<name>csv-reader-csv-parser</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value> | |
<name>CSV Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value> | |
<name>Value Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Skip Header Line</key> | |
<value> | |
<name>Skip Header Line</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ignore-csv-header</key> | |
<value> | |
<name>ignore-csv-header</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value> | |
<name>Quote Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value> | |
<name>Escape Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
<value> | |
<name>Comment Marker</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
<value> | |
<name>Null String</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value> | |
<name>Trim Fields</name> | |
</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value> | |
<name>csvutils-character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>CSVReader</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>infer-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>csv-reader-csv-parser</key> | |
<value>commons-csv</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value>custom</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value>,</value> | |
</entry> | |
<entry> | |
<key>Skip Header Line</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>ignore-csv-header</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value>"</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value>\</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.csv.CSVReader</type> | |
</controllerServices> | |
<controllerServices> | |
<id>fa35f5e3-5db4-3eea-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<comments/> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService> | |
<name>schema-cache</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value> | |
<name>schema-protocol-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value> | |
<name>CSV Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value> | |
<name>Value Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Header Line</key> | |
<value> | |
<name>Include Header Line</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value> | |
<name>Quote Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value> | |
<name>Escape Character</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
<value> | |
<name>Comment Marker</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
<value> | |
<name>Null String</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value> | |
<name>Trim Fields</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Quote Mode</key> | |
<value> | |
<name>Quote Mode</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Record Separator</key> | |
<value> | |
<name>Record Separator</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Trailing Delimiter</key> | |
<value> | |
<name>Include Trailing Delimiter</name> | |
</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value> | |
<name>csvutils-character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>CSVRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value>no-schema</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>inherit-record-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>CSV Format</key> | |
<value>custom</value> | |
</entry> | |
<entry> | |
<key>Value Separator</key> | |
<value>,</value> | |
</entry> | |
<entry> | |
<key>Include Header Line</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Quote Character</key> | |
<value>"</value> | |
</entry> | |
<entry> | |
<key>Escape Character</key> | |
<value>\</value> | |
</entry> | |
<entry> | |
<key>Comment Marker</key> | |
</entry> | |
<entry> | |
<key>Null String</key> | |
</entry> | |
<entry> | |
<key>Trim Fields</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Quote Mode</key> | |
<value>MINIMAL</value> | |
</entry> | |
<entry> | |
<key>Record Separator</key> | |
<value>\n</value> | |
</entry> | |
<entry> | |
<key>Include Trailing Delimiter</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>csvutils-character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.csv.CSVRecordSetWriter</type> | |
</controllerServices> | |
<funnels> | |
<id>29ff53b7-3a95-359c-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>1584.0</x> | |
<y>760.0</y> | |
</position> | |
</funnels> | |
<processors> | |
<id>3d15fd77-5c3b-3a02-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>288.0</x> | |
<y>632.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-gcp-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>GCP Credentials Provider Service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.gcp.credentials.service.GCPCredentialsService</identifiesControllerService> | |
<name>GCP Credentials Provider Service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-project-id</key> | |
<value> | |
<name>gcp-project-id</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-retry-count</key> | |
<value> | |
<name>gcp-retry-count</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-host</key> | |
<value> | |
<name>gcp-proxy-host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-port</key> | |
<value> | |
<name>gcp-proxy-port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-name</key> | |
<value> | |
<name>gcp-proxy-user-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-password</key> | |
<value> | |
<name>gcp-proxy-user-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-bucket</key> | |
<value> | |
<name>gcs-bucket</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-key</key> | |
<value> | |
<name>gcs-key</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-generation</key> | |
<value> | |
<name>gcs-generation</name> | |
</value> | |
</entry> | |
<entry> | |
<key>gcs-server-side-encryption-key</key> | |
<value> | |
<name>gcs-server-side-encryption-key</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>GCP Credentials Provider Service</key> | |
<value>83014ebc-1df0-37b8-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>gcp-project-id</key> | |
</entry> | |
<entry> | |
<key>gcp-retry-count</key> | |
<value>6</value> | |
</entry> | |
<entry> | |
<key>gcp-proxy-host</key> | |
</entry> | |
<entry> | |
<key>gcp-proxy-port</key> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-name</key> | |
</entry> | |
<entry> | |
<key>gcp-proxy-user-password</key> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>gcs-bucket</key> | |
<value>#{gcs_bucket}</value> | |
</entry> | |
<entry> | |
<key>gcs-key</key> | |
<value>parts_production_export.csv</value> | |
</entry> | |
<entry> | |
<key>gcs-generation</key> | |
</entry> | |
<entry> | |
<key>gcs-server-side-encryption-key</key> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>FetchGCSObject</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.gcp.storage.FetchGCSObject</type> | |
</processors> | |
<processors> | |
<id>7ac0e741-2825-3b31-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>920.0</x> | |
<y>880.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value> | |
<name>use-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
<value> | |
<name>transactional-id-prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value> | |
<name>acks</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
<value> | |
<name>attribute-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
<value> | |
<name>message-key-field</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value> | |
<name>max.request.size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value> | |
<name>ack.wait.time</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value> | |
<name>max.block.ms</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value> | |
<name>partitioner.class</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
<value> | |
<name>partition</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value> | |
<name>compression.type</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-4</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>065f16ee-13e5-347b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>fa35f5e3-5db4-3eea-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value>20 secs</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value>20 sec</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value>org.apache.kafka.clients.producer.internals.DefaultPartitioner</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value>none</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 4 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>95cf841a-8352-3c3c-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>288.0</x> | |
<y>864.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value> | |
<name>include-zero-record-flowfiles</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cache-schema</key> | |
<value> | |
<name>cache-schema</name> | |
</value> | |
</entry> | |
<entry> | |
<key>factory-1</key> | |
<value> | |
<name>factory-1</name> | |
</value> | |
</entry> | |
<entry> | |
<key>factory-2</key> | |
<value> | |
<name>factory-2</name> | |
</value> | |
</entry> | |
<entry> | |
<key>factory-3</key> | |
<value> | |
<name>factory-3</name> | |
</value> | |
</entry> | |
<entry> | |
<key>factory-4</key> | |
<value> | |
<name>factory-4</name> | |
</value> | |
</entry> | |
<entry> | |
<key>factory-5</key> | |
<value> | |
<name>factory-5</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>065f16ee-13e5-347b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>fa35f5e3-5db4-3eea-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>cache-schema</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>factory-1</key> | |
<value>Select * from FLOWFILE | |
where factory_no = 1</value> | |
</entry> | |
<entry> | |
<key>factory-2</key> | |
<value>Select * from FLOWFILE | |
where factory_no = 2</value> | |
</entry> | |
<entry> | |
<key>factory-3</key> | |
<value>Select * from FLOWFILE | |
where factory_no = 3</value> | |
</entry> | |
<entry> | |
<key>factory-4</key> | |
<value>Select * from FLOWFILE | |
where factory_no = 4</value> | |
</entry> | |
<entry> | |
<key>factory-5</key> | |
<value>Select * from FLOWFILE | |
where factory_no = 5</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Split Per Factory</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>factory-1</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>factory-2</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>factory-3</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>factory-4</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>factory-5</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.QueryRecord</type> | |
</processors> | |
<processors> | |
<id>9c431f45-e5a1-34a1-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>920.0</x> | |
<y>584.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value> | |
<name>use-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
<value> | |
<name>transactional-id-prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value> | |
<name>acks</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
<value> | |
<name>attribute-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
<value> | |
<name>message-key-field</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value> | |
<name>max.request.size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value> | |
<name>ack.wait.time</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value> | |
<name>max.block.ms</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value> | |
<name>partitioner.class</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
<value> | |
<name>partition</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value> | |
<name>compression.type</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-2</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>065f16ee-13e5-347b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>fa35f5e3-5db4-3eea-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value>5 sec</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value>20 sec</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value>org.apache.kafka.clients.producer.internals.DefaultPartitioner</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value>none</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 2 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>9e3269b8-4033-3080-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>288.0</x> | |
<y>416.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>File Size</key> | |
<value> | |
<name>File Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Batch Size</key> | |
<value> | |
<name>Batch Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Data Format</key> | |
<value> | |
<name>Data Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Unique FlowFiles</key> | |
<value> | |
<name>Unique FlowFiles</name> | |
</value> | |
</entry> | |
<entry> | |
<key>generate-ff-custom-text</key> | |
<value> | |
<name>generate-ff-custom-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value> | |
<name>character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>PRIMARY</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>File Size</key> | |
<value>0B</value> | |
</entry> | |
<entry> | |
<key>Batch Size</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>Data Format</key> | |
<value>Text</value> | |
</entry> | |
<entry> | |
<key>Unique FlowFiles</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>generate-ff-custom-text</key> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>600 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>GenerateFlowFile</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.GenerateFlowFile</type> | |
</processors> | |
<processors> | |
<id>b9d3a8e6-3452-3740-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>920.0</x> | |
<y>1024.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value> | |
<name>use-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
<value> | |
<name>transactional-id-prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value> | |
<name>acks</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
<value> | |
<name>attribute-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
<value> | |
<name>message-key-field</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value> | |
<name>max.request.size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value> | |
<name>ack.wait.time</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value> | |
<name>max.block.ms</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value> | |
<name>partitioner.class</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
<value> | |
<name>partition</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value> | |
<name>compression.type</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-5</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>065f16ee-13e5-347b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>fa35f5e3-5db4-3eea-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value>20 secs</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value>20 sec</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value>org.apache.kafka.clients.producer.internals.DefaultPartitioner</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value>none</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 5 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>c57a0f06-6da3-341f-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>920.0</x> | |
<y>736.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value> | |
<name>use-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
<value> | |
<name>transactional-id-prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value> | |
<name>acks</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
<value> | |
<name>attribute-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
<value> | |
<name>message-key-field</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value> | |
<name>max.request.size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value> | |
<name>ack.wait.time</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value> | |
<name>max.block.ms</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value> | |
<name>partitioner.class</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
<value> | |
<name>partition</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value> | |
<name>compression.type</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-3</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>065f16ee-13e5-347b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>fa35f5e3-5db4-3eea-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value>20 secs</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value>20 sec</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value>org.apache.kafka.clients.producer.internals.DefaultPartitioner</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value>none</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 3 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_2_0</type> | |
</processors> | |
<processors> | |
<id>d44ee007-d912-37ad-0000-000000000000</id> | |
<parentGroupId>c055110a-0f5f-3937-0000-000000000000</parentGroupId> | |
<position> | |
<x>920.0</x> | |
<y>424.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-kafka-2-0-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.11.4.2.0.7.0-36</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments/> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value> | |
<name>bootstrap.servers</name> | |
</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value> | |
<name>topic</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value> | |
<name>use-transactions</name> | |
</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
<value> | |
<name>transactional-id-prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value> | |
<name>acks</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
<value> | |
<name>attribute-name-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value> | |
<name>message-header-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value> | |
<name>security.protocol</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value> | |
<name>sasl.mechanism</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
<value> | |
<name>sasl.kerberos.service.name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
<value> | |
<name>sasl.kerberos.principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
<value> | |
<name>sasl.kerberos.keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value> | |
<name>sasl.username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
<value> | |
<name>sasl.password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value> | |
<name>sasl.token.auth</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>ssl.context.service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
<value> | |
<name>message-key-field</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value> | |
<name>max.request.size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value> | |
<name>ack.wait.time</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value> | |
<name>max.block.ms</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value> | |
<name>partitioner.class</name> | |
</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
<value> | |
<name>partition</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value> | |
<name>compression.type</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>bootstrap.servers</key> | |
<value>#{kafkabrokers}</value> | |
</entry> | |
<entry> | |
<key>topic</key> | |
<value>Factory-1</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>065f16ee-13e5-347b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>fa35f5e3-5db4-3eea-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>use-transactions</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>transactional-id-prefix</key> | |
</entry> | |
<entry> | |
<key>acks</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>attribute-name-regex</key> | |
</entry> | |
<entry> | |
<key>message-header-encoding</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>security.protocol</key> | |
<value>SASL_SSL</value> | |
</entry> | |
<entry> | |
<key>sasl.mechanism</key> | |
<value>PLAIN</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.service.name</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.principal</key> | |
</entry> | |
<entry> | |
<key>sasl.kerberos.keytab</key> | |
</entry> | |
<entry> | |
<key>sasl.username</key> | |
<value>#{username}</value> | |
</entry> | |
<entry> | |
<key>sasl.password</key> | |
</entry> | |
<entry> | |
<key>sasl.token.auth</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>ssl.context.service</key> | |
<value>af153d08-e961-36c3-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>message-key-field</key> | |
</entry> | |
<entry> | |
<key>max.request.size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>ack.wait.time</key> | |
<value>5 sec</value> | |
</entry> | |
<entry> | |
<key>max.block.ms</key> | |
<value>20 sec</value> | |
</entry> | |
<entry> | |
<key>partitioner.class</key> | |
<value>org.apache.kafka.clients.producer.internals.DefaultPartitioner</value> | |
</entry> | |
<entry> | |
<key>partition</key> | |
</entry> | |
<entry> | |
<key>compression.type</key> | |
<value>none</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Factory 1 Kafka Stream</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_2_0</type> | |
</processors> | |
</contents> | |
<name>Push to Kafka</name> | |
<variables/> | |
</processGroups> | |
</snippet> | |
<timestamp>03/29/2021 03:08:52 UTC</timestamp> | |
</template> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment