[
https://issues.apache.org/jira/browse/NIFI-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Witt updated NIFI-6856:
---------------------------
Fix Version/s: 1.11.4
> 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
> Priority: Minor
> Fix For: 1.12.0, 1.11.4
>
> Time Spent: 50m
> Remaining Estimate: 0h
>
> 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)
