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 <yash.ma...@gmail.com>
AuthorDate: Thu Sep 8 14:57:06 2022 +0530
MINOR: Fix usage of @see in IncrementalCooperativeAssignor doc comments
(#12606)
Reviewers: Mickael Maison <mickael.mai...@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
