Skip to content

Instantly share code, notes, and snippets.

@asdaraujo

asdaraujo/collect-cloud-data-gcp.xml

Created March 29, 2021 03:52
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save asdaraujo/cf8b05c7121e9f10c1b75d608651539e to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save asdaraujo/cf8b05c7121e9f10c1b75d608651539e to your computer and use it in GitHub Desktop.
Download ZIP
Raw
collect-cloud-data-gcp.xml
<?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>&quot;</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>&quot;</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>&quot;</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 *, &apos;beta_engine&apos; as Status
from FLOWFILE
where part_no = &apos;a42CLDR&apos;
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>&quot;</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>&quot;</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