You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2022/09/08 09:27:39 UTC
[kafka] branch trunk updated: MINOR: Fix usage of @see in IncrementalCooperativeAssignor doc comments (#12606)
This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 9b947a5ca3 MINOR: Fix usage of @see in IncrementalCooperativeAssignor doc comments (#12606)
9b947a5ca3 is described below
commit 9b947a5ca399be76d62f934c9c08249f54a0f191
Author: Yash Mayya <ya...@gmail.com>
AuthorDate: Thu Sep 8 14:57:06 2022 +0530
MINOR: Fix usage of @see in IncrementalCooperativeAssignor doc comments (#12606)
Reviewers: Mickael Maison <mi...@gmail.com>
---
.../runtime/distributed/IncrementalCooperativeAssignor.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
index 57e7b00485..270bb5263f 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
@@ -53,11 +53,10 @@ import static org.apache.kafka.connect.util.ConnectUtils.transformValues;
/**
* An assignor that computes a distribution of connectors and tasks according to the incremental
- * cooperative strategy for rebalancing. {@see
- * https://cwiki.apache.org/confluence/display/KAFKA/KIP-415%3A+Incremental+Cooperative
- * +Rebalancing+in+Kafka+Connect} for a description of the assignment policy.
+ * cooperative strategy for rebalancing. Note that this class is NOT thread-safe.
+ * @see <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-415%3A+Incremental+Cooperative+Rebalancing+in+Kafka+Connect">
+ * KIP-415 for a description of the assignment policy. </a>
*
- * Note that this class is NOT thread-safe.
*/
public class IncrementalCooperativeAssignor implements ConnectAssignor {
private final Logger log;
@@ -143,7 +142,8 @@ public class IncrementalCooperativeAssignor implements ConnectAssignor {
/**
* Performs task assignment based on the incremental cooperative connect protocol.
* Read more on the design and implementation in:
- * {@see https://cwiki.apache.org/confluence/display/KAFKA/KIP-415%3A+Incremental+Cooperative+Rebalancing+in+Kafka+Connect}
+ * <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-415%3A+Incremental+Cooperative+Rebalancing+in+Kafka+Connect">
+ * KIP-415</a>
*
* @param leaderId the ID of the group leader
* @param maxOffset the latest known offset of the configuration topic