KIP-429: Kafka Consumer Incremental Rebalance Protocol

[robsonpeixoto]

Are there plans to add "Kafka Consumer Incremental Rebalance Protocol" support?

References:

• https://cwiki.apache.org/confluence/display/KAFKA/KIP-429%3A+Kafka+Consumer+Incremental+Rebalance+Protocol
• https://www.confluent.io/blog/incremental-cooperative-rebalancing-in-kafka/

[zmstone]

Hi. @robsonpeixoto
No, not at the moment .

[zmstone]

Just to clarify a bit.
Brod has the apis ready for this.

If one wants a different partition assignment strategy, they need to implement this behavior

brod/src/brod_group_member.erl

Line 55 in c34fa87

-optional_callbacks([assign_partitions/3,

For incremental rebalancing, one should not have to revoke assignments.

brod/src/brod_group_member.erl

Line 87 in c34fa87

-callback assignments_revoked(pid()) -> ok.