[
https://issues.apache.org/jira/browse/KAFKA-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17048452#comment-17048452
]
ASF GitHub Bot commented on KAFKA-9525:
---------------------------------------
guozhangwang commented on pull request #8087: KAFKA-9525: add enforceRebalance
method to Consumer API
URL: https://github.com/apache/kafka/pull/8087
----------------------------------------------------------------
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)
