root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix AbstractStickyAssignor doc (#11727) 

Reviewers: David Jacot <djacot@confluent.io>
This commit is contained in:
Kvicii 2022-02-03 17:54:54 +08:00 committed by GitHub
parent af6a9a17bf
commit 23771cd27c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
View File

@ -490,7 +490,7 @@ public abstract class AbstractStickyAssignor extends AbstractPartitionAssignor {
*
* We loop the sortedPartition, and compare the ith element in sortedAssignedPartitions(i start from 0):
* - if not equal to the ith element, add to unassignedPartitions
* - if equal to the the ith element, get next element from sortedAssignedPartitions
* - if equal to the ith element, get next element from sortedAssignedPartitions
*
* @param sortedAllPartitions: sorted all partitions
* @param sortedAssignedPartitions: sorted partitions, all are included in the sortedPartitions
@ -538,7 +538,7 @@ public abstract class AbstractStickyAssignor extends AbstractPartitionAssignor {
* We loop through the all sorted topics, and then iterate all partitions the topic has,
* compared with the ith element in sortedAssignedPartitions(i starts from 0):
* - if not equal to the ith element, add to unassignedPartitions
* - if equal to the the ith element, get next element from sortedAssignedPartitions
* - if equal to the ith element, get next element from sortedAssignedPartitions
*
* @param totalPartitionsCount all partitions counts in this assignment
* @param partitionsPerTopic the number of partitions for each subscribed topic.
@ -588,7 +588,7 @@ public abstract class AbstractStickyAssignor extends AbstractPartitionAssignor {
/**
* update the prevAssignment with the partitions, consumer and generation in parameters
*
* @param partitions: The partitions to be updated the prevAssignement
* @param partitions: The partitions to be updated the prevAssignment
* @param consumer: The consumer Id
* @param prevAssignment: The assignment contains the assignment with the 2nd largest generation
* @param generation: The generation of this assignment (partitions)