ableegoldman commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r418793644
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##########
@@ -1009,14 +1018,18 @@ private void addClientAssignments(final Map<String,
Assignment> assignment,
AssignorError.NONE.code()
);
- if (encodeNextRebalanceTime) {
+ if (tasksRevoked) {
+ // TODO: once KAFKA-9821 is resolved we can leave it to the
client to trigger this rebalance
+ log.debug("Requesting followup rebalance be scheduled
immediately due to tasks changing ownership.");
+ info.setNextRebalanceTime(0L);
Review comment:
This encodes an immediate followup rebalance for the consumer who would
be receiving the revoked tasks. The consumer that is doing the revoking will
also request a followup rebalance (in the client code) but due to KAFKA-9821
this cannot be relied upon when static membership is used.
----------------------------------------------------------------
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:
[email protected]
