MiNiFi Config Version: 3 Flow Controller: name: pushkafka1 comment: '' Core Properties: flow controller graceful shutdown period: 10 sec flow service write delay interval: 500 ms administrative yield duration: 30 sec bored yield duration: 10 millis max concurrent threads: 1 variable registry properties: '' FlowFile Repository: partitions: 256 checkpoint interval: 2 mins always sync: false Swap: threshold: 20000 in period: 5 sec in threads: 1 out period: 5 sec out threads: 4 Content Repository: content claim max appendable size: 10 MB content claim max flow files: 100 always sync: false Provenance Repository: provenance rollover time: 1 min implementation: org.apache.nifi.provenance.MiNiFiPersistentProvenanceRepository Component Status Repository: buffer size: 1440 snapshot frequency: 1 min Security Properties: keystore: '' keystore type: '' keystore password: '' key password: '' truststore: '' truststore type: '' truststore password: '' ssl protocol: '' Sensitive Props: key: algorithm: PBEWITHMD5AND256BITAES-CBC-OPENSSL provider: BC Processors: - id: 97f29c0a-1173-3dd1-0000-000000000000 name: Add Schema class: org.apache.nifi.processors.attributes.UpdateAttribute max concurrent tasks: 1 scheduling strategy: TIMER_DRIVEN scheduling period: 0 sec penalization period: 30 sec yield period: 1 sec run duration nanos: 0 auto-terminated relationships list: [] Properties: Delete Attributes Expression: Stateful Variables Initial Value: Store State: Do not store state content-type: application/json content.type: application/json mime-type: application/json mime.type: application/json schema: smartPlug schema-name: smartPlug schema.name: smartPlug schemaName: smartPlug - id: c84a9ca4-5fd3-323d-0000-000000000000 name: Monitor Power class: org.apache.nifi.processors.standard.ExecuteProcess max concurrent tasks: 1 scheduling strategy: TIMER_DRIVEN scheduling period: 1 sec penalization period: 30 sec yield period: 1 sec run duration nanos: 0 auto-terminated relationships list: [] Properties: Argument Delimiter: ' ' Batch Duration: Command: /Volumes/TSPANN/projects/nifi-smartplug/smartreader.sh Command Arguments: Redirect Error Stream: 'false' Working Directory: /Volumes/TSPANN/projects/nifi-smartplug - id: db05a089-1817-3d99-0000-000000000000 name: PublishKafka_1_0 class: org.apache.nifi.processors.kafka.pubsub.PublishKafka_1_0 max concurrent tasks: 1 scheduling strategy: TIMER_DRIVEN scheduling period: 0 sec penalization period: 30 sec yield period: 1 sec run duration nanos: 0 auto-terminated relationships list: - success Properties: ack.wait.time: 5 secs acks: '0' attribute-name-regex: bootstrap.servers: princeton1.field.hortonworks.com:6667 compression.type: none kafka-key: ${uuid} kerberos-credentials-service: key-attribute-encoding: utf-8 max.block.ms: 5 sec max.request.size: 1 MB message-demarcator: message-header-encoding: UTF-8 partitioner.class: org.apache.kafka.clients.producer.internals.DefaultPartitioner sasl.kerberos.keytab: sasl.kerberos.principal: sasl.kerberos.service.name: security.protocol: PLAINTEXT ssl.context.service: topic: smartPlug use-transactions: 'false' - id: 91f332cb-08ce-3fe9-0000-000000000000 name: PutFile class: org.apache.nifi.processors.standard.PutFile max concurrent tasks: 1 scheduling strategy: TIMER_DRIVEN scheduling period: 0 sec penalization period: 30 sec yield period: 1 sec run duration nanos: 0 auto-terminated relationships list: - failure - success Properties: Conflict Resolution Strategy: ignore Create Missing Directories: 'true' Directory: /tmp Group: Last Modified Time: Maximum File Count: Owner: Permissions: Controller Services: [] Process Groups: [] Input Ports: [] Output Ports: [] Funnels: [] Connections: - id: d6aced50-4fea-33e7-0000-000000000000 name: Add Schema/success/PublishKafka_1_0 source id: 97f29c0a-1173-3dd1-0000-000000000000 source relationship names: - success destination id: db05a089-1817-3d99-0000-000000000000 max work queue size: 120000 max work queue data size: 1 GB flowfile expiration: 0 sec queue prioritizer class: '' - id: de5f207d-3b80-364b-0000-000000000000 name: Monitor Power/success/Add Schema source id: c84a9ca4-5fd3-323d-0000-000000000000 source relationship names: - success destination id: 97f29c0a-1173-3dd1-0000-000000000000 max work queue size: 120000 max work queue data size: 1 GB flowfile expiration: 0 sec queue prioritizer class: '' - id: 22d229e9-c64e-37c5-0000-000000000000 name: PublishKafka_1_0/failure/PutFile source id: db05a089-1817-3d99-0000-000000000000 source relationship names: - failure destination id: 91f332cb-08ce-3fe9-0000-000000000000 max work queue size: 120000 max work queue data size: 1 GB flowfile expiration: 0 sec queue prioritizer class: '' Remote Process Groups: [] NiFi Properties Overrides: {}