(kafka) branch trunk updated: MINOR: fix typo in KafkaAdminClient to align the meaning (#21988)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 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 112686cfa8f MINOR: fix typo in KafkaAdminClient to align the meaning 
(#21988)
112686cfa8f is described below

commit 112686cfa8f40a43a9297bb0da49baf50609c562
Author: Chia-Yi Chiu <cych...@gmail.com>
AuthorDate: Wed Apr 8 14:25:53 2026 +0900

    MINOR: fix typo in KafkaAdminClient to align the meaning (#21988)
    
    Summary: fix the typo `addResponse` to `removeResponse` to align the
    meaning of the code.
    
    Reviewers: Ken Huang <s7133...@gmail.com>, Jiayao Sun
     <jiaya...@outlook.com>, Chia-Ping Tsai   <chia7...@gmail.com>
---
 .../main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java 
b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
index 8ca79899421..2eb0e8d07a0 100644
--- a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
+++ b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
@@ -5051,10 +5051,10 @@ public class KafkaAdminClient extends AdminClient {
             @Override
             void handleResponse(AbstractResponse response) {
                 handleNotControllerError(response);
-                RemoveRaftVoterResponse addResponse = 
(RemoveRaftVoterResponse) response;
-                Errors error = Errors.forCode(addResponse.data().errorCode());
+                RemoveRaftVoterResponse removeResponse = 
(RemoveRaftVoterResponse) response;
+                Errors error = 
Errors.forCode(removeResponse.data().errorCode());
                 if (error != Errors.NONE)
-                    
future.completeExceptionally(error.exception(addResponse.data().errorMessage()));
+                    
future.completeExceptionally(error.exception(removeResponse.data().errorMessage()));
                 else
                     future.complete(null);
             }