feat(linking): use linkId for update group API (#2352)

Signed-off-by: Shichao Nie <[email protected]>

Author: SCNieh

clients/src/main/java/org/apache/kafka/clients/admin/UpdateGroupSpec.java

@@ -14,11 +14,11 @@
 import java.util.Objects;
 
 public class UpdateGroupSpec {
-    private String clusterId;
+    private String linkId;
     private boolean promoted;
 
-    public UpdateGroupSpec clusterId(String clusterId) {
-        this.clusterId = clusterId;
+    public UpdateGroupSpec linkId(String linkId) {
+        this.linkId = linkId;
         return this;
     }
 
@@ -27,8 +27,8 @@ public UpdateGroupSpec promoted(boolean promoted) {
         return this;
     }
 
-    public String clusterId() {
-        return clusterId;
+    public String linkId() {
+        return linkId;
     }
 
     public boolean promoted() {
@@ -42,18 +42,18 @@ public boolean equals(Object o) {
         if (o == null || getClass() != o.getClass())
             return false;
         UpdateGroupSpec spec = (UpdateGroupSpec) o;
-        return promoted == spec.promoted && Objects.equals(clusterId, spec.clusterId);
+        return promoted == spec.promoted && Objects.equals(linkId, spec.linkId);
     }
 
     @Override
     public int hashCode() {
-        return Objects.hash(clusterId, promoted);
+        return Objects.hash(linkId, promoted);
     }
 
     @Override
     public String toString() {
         return "UpdateGroupsSpec{" +
-            "clusterId='" + clusterId + '\'' +
+            "linkId='" + linkId + '\'' +
             ", promoted=" + promoted +
             '}';
     }

clients/src/main/java/org/apache/kafka/clients/admin/internals/UpdateGroupHandler.java

@@ -86,7 +86,7 @@ public AutomqUpdateGroupRequest.Builder buildBatchedRequest(
         validateKeys(groupIds);
         return new AutomqUpdateGroupRequest.Builder(
             new AutomqUpdateGroupRequestData()
-                .setClusterId(groupSpec.clusterId())
+                .setLinkId(groupSpec.linkId())
                 .setGroupId(this.groupId.idValue)
                 .setPromoted(groupSpec.promoted())
         );

clients/src/main/resources/common/message/AutomqUpdateGroupRequest.json

@@ -24,10 +24,10 @@
   "flexibleVersions": "0+",
   "fields": [
     {
-      "name": "ClusterId",
+      "name": "LinkId",
       "type": "string",
       "versions": "0+",
-      "about": "The unique cluster ID which used for identification of the cluster to be linked"
+      "about": "The unique ID of a kafka link"
     },
     {
       "name": "GroupId",