[
https://issues.apache.org/jira/browse/MINIFICPP-722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16752556#comment-16752556
]
Prasad Alokam edited comment on MINIFICPP-722 at 1/25/19 6:37 PM:
------------------------------------------------------------------
config.yml
-------
MiNiFi Config Version: 3
Flow Controller:
name: MQTT
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: a3f9f561-8915-358f-0000-000000000000
name: ConsumeMQTT
class: org.apache.nifi.processors.mqtt.ConsumeMQTT
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 30 sec
penalization period: 30 sec
yield period: 10 sec
run duration nanos: 0
auto-terminated relationships list: []
Properties:
Broker URI: tcp://localhost:1883
Client ID: mqttclientconsume
Connection Timeout (seconds): '30'
Keep Alive Interval (seconds): '60'
Last Will Message:
Last Will QoS Level:
Last Will Retain:
Last Will Topic:
MQTT Specification Version: '0'
Max Queue Size: '1024'
Password:
Quality of Service(QoS): '0'
SSL Context Service:
Session state: 'true'
Topic Filter: nifi
Username:
- id: eb4c6a60-82d7-39b0-0000-000000000000
name: PublishMQTT
class: org.apache.nifi.processors.mqtt.PublishMQTT
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 0 sec
penalization period: 30 sec
yield period: 10 sec
run duration nanos: 0
auto-terminated relationships list:
- failure
- success
Properties:
Broker URI: tcp://localhost:1883
Client ID: mqttpublishclient
Connection Timeout (seconds): '30'
Keep Alive Interval (seconds): '60'
Last Will Message: test
Last Will QoS Level: '0'
Last Will Retain: 'true'
Last Will Topic: nifi
MQTT Specification Version: '0'
Password:
Quality of Service(QoS): '0'
Retain Message: 'true'
SSL Context Service:
Session state: 'true'
Topic: nifi
Username:
- id: f9edfac1-973e-35e3-0000-000000000000
name: ReplaceText
class: org.apache.nifi.processors.standard.ReplaceText
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 0 sec
penalization period: 30 sec
yield period: 10 sec
run duration nanos: 0
auto-terminated relationships list: []
Properties:
Character Set: UTF-8
Evaluation Mode: Entire text
Maximum Buffer Size: 1 MB
Regular Expression: test
Replacement Strategy: Regex Replace
Replacement Value: test12
Controller Services: []
Process Groups: []
Input Ports: []
Output Ports: []
Funnels: []
Connections:
- id: 0598788a-0146-30bf-0000-000000000000
name: ConsumeMQTT/Message/ReplaceText
source id: a3f9f561-8915-358f-0000-000000000000
source relationship names:
- Message
destination id: f9edfac1-973e-35e3-0000-000000000000
max work queue size: 10000
max work queue data size: 1 GB
flowfile expiration: 0 sec
queue prioritizer class: ''
- id: 1f2cc47a-413a-3dea-0000-000000000000
name: ReplaceText/failure/PublishMQTT
source id: f9edfac1-973e-35e3-0000-000000000000
source relationship names:
- failure
- success
destination id: eb4c6a60-82d7-39b0-0000-000000000000
max work queue size: 10000
max work queue data size: 1 GB
flowfile expiration: 0 sec
queue prioritizer class: ''
Remote Process Groups: []
NiFi Properties Overrides: {}
------
was (Author: palokam):
MiNiFi Config Version: 3
Flow Controller:
name: MQTT
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: a3f9f561-8915-358f-0000-000000000000
name: ConsumeMQTT
class: org.apache.nifi.processors.mqtt.ConsumeMQTT
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 30 sec
penalization period: 30 sec
yield period: 10 sec
run duration nanos: 0
auto-terminated relationships list: []
Properties:
Broker URI: tcp://localhost:1883
Client ID: mqttclientconsume
Connection Timeout (seconds): '30'
Keep Alive Interval (seconds): '60'
Last Will Message:
Last Will QoS Level:
Last Will Retain:
Last Will Topic:
MQTT Specification Version: '0'
Max Queue Size: '1024'
Password:
Quality of Service(QoS): '0'
SSL Context Service:
Session state: 'true'
Topic Filter: nifi
Username:
- id: eb4c6a60-82d7-39b0-0000-000000000000
name: PublishMQTT
class: org.apache.nifi.processors.mqtt.PublishMQTT
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 0 sec
penalization period: 30 sec
yield period: 10 sec
run duration nanos: 0
auto-terminated relationships list:
- failure
- success
Properties:
Broker URI: tcp://localhost:1883
Client ID: mqttpublishclient
Connection Timeout (seconds): '30'
Keep Alive Interval (seconds): '60'
Last Will Message: test
Last Will QoS Level: '0'
Last Will Retain: 'true'
Last Will Topic: nifi
MQTT Specification Version: '0'
Password:
Quality of Service(QoS): '0'
Retain Message: 'true'
SSL Context Service:
Session state: 'true'
Topic: nifi
Username:
- id: f9edfac1-973e-35e3-0000-000000000000
name: ReplaceText
class: org.apache.nifi.processors.standard.ReplaceText
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 0 sec
penalization period: 30 sec
yield period: 10 sec
run duration nanos: 0
auto-terminated relationships list: []
Properties:
Character Set: UTF-8
Evaluation Mode: Entire text
Maximum Buffer Size: 1 MB
Regular Expression: test
Replacement Strategy: Regex Replace
Replacement Value: test12
Controller Services: []
Process Groups: []
Input Ports: []
Output Ports: []
Funnels: []
Connections:
- id: 0598788a-0146-30bf-0000-000000000000
name: ConsumeMQTT/Message/ReplaceText
source id: a3f9f561-8915-358f-0000-000000000000
source relationship names:
- Message
destination id: f9edfac1-973e-35e3-0000-000000000000
max work queue size: 10000
max work queue data size: 1 GB
flowfile expiration: 0 sec
queue prioritizer class: ''
- id: 1f2cc47a-413a-3dea-0000-000000000000
name: ReplaceText/failure/PublishMQTT
source id: f9edfac1-973e-35e3-0000-000000000000
source relationship names:
- failure
- success
destination id: eb4c6a60-82d7-39b0-0000-000000000000
max work queue size: 10000
max work queue data size: 1 GB
flowfile expiration: 0 sec
queue prioritizer class: ''
Remote Process Groups: []
NiFi Properties Overrides: {}
> MQTT Processor failing - but cmake is fine
> ------------------------------------------
>
> Key: MINIFICPP-722
> URL: https://issues.apache.org/jira/browse/MINIFICPP-722
> Project: NiFi MiNiFi C++
> Issue Type: Bug
> Reporter: Prasad Alokam
> Priority: Blocker
>
> CMAKE options used:
> cmake -DSKIP_TESTS=true .. -DENABLE_MQTT=TRUE -DCMAKE_CXX_FLAGS=-lrt
> -DDISABLE_ROCKSDB=true
>
> No errors in CMAKE
> Run time image have a problem
>
> (MiNiFi) running with PID 17.
> {color:#FF0000}Error loading shared library libpaho-mqtt3c.so.1: No such file
> or directory (needed by /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi){color}
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_setCallbacks: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_subscribe: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_unsubscribe: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_disconnect: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_isConnected: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_publishMessage: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_freeMessage: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_connect: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_free: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_destroy: symbol not found
> Error relocating /opt/minifi/nifi-minifi-cpp-0.5.0/bin/minifi:
> MQTTClient_create: symbol not found
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
