[
https://issues.apache.org/jira/browse/KAFKA-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034116#comment-17034116
]
ASF GitHub Bot commented on KAFKA-9525:
---------------------------------------
ableegoldman commented on pull request #8087: KAFKA-9525: add enforceRebalance
method to Consumer API
URL: https://github.com/apache/kafka/pull/8087
As described in
[KIP-568](https://cwiki.apache.org/confluence/display/KAFKA/KIP-568%3A+Explicit+rebalance+triggering+on+the+Consumer).
Waiting on acceptance of the KIP to write the tests, on the off chance
something changes. But rest assured unit tests are coming ⚡️
Will also kick off existing Streams system tests which leverage this new API
(eg version probing, sometimes broker bounce)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Allow explicit rebalance triggering on the Consumer
> ---------------------------------------------------
>
> Key: KAFKA-9525
> URL: https://issues.apache.org/jira/browse/KAFKA-9525
> Project: Kafka
> Issue Type: Improvement
> Components: clients
> Reporter: Sophie Blee-Goldman
> Assignee: Sophie Blee-Goldman
> Priority: Major
> Labels: needs-kip
>
> Currently the only way to explicitly trigger a rebalance is by unsubscribing
> the consumer. This has two drawbacks: it does not work with static
> membership, and it causes the consumer to revoke all its currently owned
> partitions. Streams relies on being able to enforce a rebalance for its
> version probing upgrade protocol and the upcoming KIP-441, both of which
> should be able to work with static membership and be able to leverage the
> improvements of KIP-429 to no longer revoke all owned partitions.
> We should add an API that will allow users to explicitly trigger a rebalance
> without going through #unsubscribe
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
