Skip to content

Commit 112686c

Browse files
authored
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 <s7133700@gmail.com>, Jiayao Sun <jiayao.s@outlook.com>, Chia-Ping Tsai <chia7712@gmail.com>
1 parent 40e9fcd commit 112686c

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5051,10 +5051,10 @@ RemoveRaftVoterRequest.Builder createRequest(int timeoutMs) {
50515051
@Override
50525052
void handleResponse(AbstractResponse response) {
50535053
handleNotControllerError(response);
5054-
RemoveRaftVoterResponse addResponse = (RemoveRaftVoterResponse) response;
5055-
Errors error = Errors.forCode(addResponse.data().errorCode());
5054+
RemoveRaftVoterResponse removeResponse = (RemoveRaftVoterResponse) response;
5055+
Errors error = Errors.forCode(removeResponse.data().errorCode());
50565056
if (error != Errors.NONE)
5057-
future.completeExceptionally(error.exception(addResponse.data().errorMessage()));
5057+
future.completeExceptionally(error.exception(removeResponse.data().errorMessage()));
50585058
else
50595059
future.complete(null);
50605060
}

0 commit comments

Comments
 (0)