MiNiFi Config Version: 3 Flow Controller: name: consumekafka2 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: 0628b4e5-10d0-3b09-0000-000000000000 name: AttributesToJSON class: org.apache.nifi.processors.standard.AttributesToJSON 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 Properties: Attributes List: Destination: flowfile-content Include Core Attributes: 'true' Null Value: 'false' attributes-to-json-regex: - id: 8556f1ce-a915-3fda-0000-000000000000 name: ConsumeKafka_1_0 class: org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_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: [] Properties: auto.offset.reset: latest bootstrap.servers: princeton1.field.hortonworks.com:6667 group.id: minificonsumer1 header-name-regex: .* honor-transactions: 'false' kerberos-credentials-service: key-attribute-encoding: utf-8 max-uncommit-offset-wait: 1 secs max.poll.records: '10000' message-demarcator: message-header-encoding: UTF-8 sasl.kerberos.keytab: sasl.kerberos.principal: sasl.kerberos.service.name: security.protocol: PLAINTEXT ssl.context.service: topic: smartPlug topic_type: names - id: 25a86505-031a-37d9-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: /Volumes/TSPANN/apps/minifi-0.5.0/logs/monitor Group: Last Modified Time: Maximum File Count: Owner: Permissions: - id: 9220d40d-ee1d-3f61-0000-000000000000 name: UpdateAttribute 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 filename: ${filename:append('.attr.json')} Controller Services: [] Process Groups: [] Input Ports: [] Output Ports: [] Funnels: [] Connections: - id: d9d1659b-5e91-3d35-0000-000000000000 name: AttributesToJSON/success/UpdateAttribute source id: 0628b4e5-10d0-3b09-0000-000000000000 source relationship names: - success destination id: 9220d40d-ee1d-3f61-0000-000000000000 max work queue size: 15000 max work queue data size: 1 GB flowfile expiration: 0 sec queue prioritizer class: '' - id: 94610ca9-0b02-3f7c-0000-000000000000 name: ConsumeKafka_1_0/success/AttributesToJSON source id: 8556f1ce-a915-3fda-0000-000000000000 source relationship names: - success destination id: 0628b4e5-10d0-3b09-0000-000000000000 max work queue size: 15000 max work queue data size: 1 GB flowfile expiration: 0 sec queue prioritizer class: '' - id: 9c2da79b-8946-3a27-0000-000000000000 name: ConsumeKafka_1_0/success/PutFile source id: 8556f1ce-a915-3fda-0000-000000000000 source relationship names: - success destination id: 25a86505-031a-37d9-0000-000000000000 max work queue size: 15000 max work queue data size: 1 GB flowfile expiration: 0 sec queue prioritizer class: '' - id: 62f8acf5-9ae2-3904-0000-000000000000 name: UpdateAttribute/success/PutFile source id: 9220d40d-ee1d-3f61-0000-000000000000 source relationship names: - success destination id: 25a86505-031a-37d9-0000-000000000000 max work queue size: 15000 max work queue data size: 1 GB flowfile expiration: 0 sec queue prioritizer class: '' Remote Process Groups: [] NiFi Properties Overrides: {}