[jira] [Resolved] (NIFI-6856) Support MQTT consumer groups

["Pierre Villard (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/NIFI-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Pierre Villard resolved NIFI-6856.
----------------------------------
    Fix Version/s: 1.12.0
       Resolution: Fixed

> 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
>
>          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)