partition.assignment.strategy must accept an array of values

[MacPower]

Hi,

The kafka input plugin must accept an array of values for the partition.assignment.strategy. As describe in the documentation the assignment strategy is a list and can accept multiple values.

This property accepts a comma-separated list of strategies. For example, it allows to update a group of consumers by specifying a new strategy while temporarily keeping the previous one. Part of the Rebalance Protocol the broker coordinator will choose the protocol which is supported by all members.

By default the strategy is class org.apache.kafka.clients.consumer.RangeAssignor if I want to change to org.apache.kafka.clients.consumer.RoundRobinAssignor I need to stop consuming from my consumer group (so stopping all my instances) , change the strategy and then restart consuming from the topic with the new strategy.

If we specify a new strategy with an active consumer group, this result in the following error:

Error: The group member's supported protocols are incompatible with those of existing members or first group member tried to join with empty protocol type or empty protocol list.
  Exception: Java::OrgApacheKafkaCommonErrors::InconsistentGroupProtocolException

Wich is totally normal.

Could this be implemented ?

Thank you.