[
https://issues.apache.org/jira/browse/NIFI-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261149#comment-16261149
]
ASF GitHub Bot commented on NIFI-4463:
--------------------------------------
Github user joewitt commented on the issue:
https://github.com/apache/nifi/pull/2241
@dometec thanks for your contribution and particularly for it being such a
substantive one. This will require someone to give it a good review/test
cycle. Apologies for the delay but hopefully someone will soon jump on this.
> 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)
