Justin Miller created NIFI-6856:
-----------------------------------
Summary: Support MQTT consumer groups
Key: NIFI-6856
URL: https://issues.apache.org/jira/browse/NIFI-6856
Project: Apache NiFi
Issue Type: Improvement
Affects Versions: 1.11.0
Reporter: Justin Miller
Multiple MQTT brokers including HiveMQ and EMQX support MQTT consumer groups,
which provide a way of horizontally scaling and load balancing MQTT consumers.
This feature is built on the MQTTv5 protocol but all the logic is handled
server side, so any MQTT client can take advantage of these features:
[https://docs.emqx.io/tutorial/v3/en/advanced/share_subscribe.html.]
Right now ConsumeMQTT cannot take advantage of this horizontal scaling because
client ID is required and does not support expression language. Making the
client id optional and defaulting to a uuid along with adding a group id field
that sets the consumer to join the consumer group would open up the ability to
take advantage of these broker features.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
