Stefano Melzi created NIFI-4463:
-----------------------------------
Summary: MQTT client disconnection in ConsumeMQTT Processor
Key: NIFI-4463
URL: https://issues.apache.org/jira/browse/NIFI-4463
Project: Apache NiFi
Issue Type: Bug
Components: Core Framework
Affects Versions: 1.3.0
Environment: OS: Centos /
MQTT Borker: mosquitto
Reporter: Stefano Melzi
Priority: Minor
When internal queue is full the messageArrived method throws an exception
causing the MQTT client to disconnect. This event is managed creating a new
client which try to reconnect to the broker.
In our test using a mosquitto broker with a high mqtt traffic and a low value
for "Max Queue Size" property we experiment broker disconnection when internal
queue is full, but after this event MQTT Processor remains blocked without any
attempt to reconnect.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
