tim-patterson commented on a change in pull request #11760:
URL: https://github.com/apache/kafka/pull/11760#discussion_r815521489
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java
##########
@@ -56,25 +54,34 @@ private int numCaughtUpClients() {
return caughtUpClients.size();
}
- private static boolean
taskIsNotCaughtUpOnClientAndOtherCaughtUpClientsExist(final TaskId task,
-
final UUID client,
-
final Map<TaskId, SortedSet<UUID>> tasksToCaughtUpClients) {
- return !taskIsCaughtUpOnClientOrNoCaughtUpClientsExist(task, client,
tasksToCaughtUpClients);
+ private static boolean
taskIsNotCaughtUpOnClientAndOtherMoreCaughtUpClientsExist(final TaskId task,
+
final UUID client,
+
final Map<UUID, ClientState> clientStates,
+
final Map<TaskId, SortedSet<UUID>> tasksToCaughtUpClients,
+
final Map<TaskId, List<UUID>> tasksToClientByLag) {
Review comment:
Sure I've pushed up a commit that does this.
My only concern is that these `SortedSet`'s now end up holding a reference
to `clientStates` rather than just being a plain old list/set etc.
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
