This is an automated email from the ASF dual-hosted git repository.
schofielaj 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 d840776ed7d MINOR: Fix typo 'reqeust' to 'request' in
NetworkPartitionMetadataClientTest (#21945)
d840776ed7d is described below
commit d840776ed7dc20caf8747ea7a142a09f49345915
Author: 조형준 <[email protected]>
AuthorDate: Fri Apr 3 16:28:50 2026 +0900
MINOR: Fix typo 'reqeust' to 'request' in
NetworkPartitionMetadataClientTest (#21945)
Fix typo in local variable name `pendingReqeust` -> `pendingRequest` in
`NetworkPartitionMetadataClientTest`.
Reviewers: Andrew Schofield <[email protected]>
---
.../server/util/NetworkPartitionMetadataClientTest.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/server/src/test/java/org/apache/kafka/server/util/NetworkPartitionMetadataClientTest.java
b/server/src/test/java/org/apache/kafka/server/util/NetworkPartitionMetadataClientTest.java
index 4307ca90722..8e82721d416 100644
---
a/server/src/test/java/org/apache/kafka/server/util/NetworkPartitionMetadataClientTest.java
+++
b/server/src/test/java/org/apache/kafka/server/util/NetworkPartitionMetadataClientTest.java
@@ -300,12 +300,12 @@ class NetworkPartitionMetadataClientTest {
networkPartitionMetadataClient =
NetworkPartitionMetadataClientBuilder.builder().build();
Node node = mock(Node.class);
ListOffsetsRequest.Builder builder =
mock(ListOffsetsRequest.Builder.class);
- NetworkPartitionMetadataClient.PendingRequest pendingReqeust = new
NetworkPartitionMetadataClient.PendingRequest(
+ NetworkPartitionMetadataClient.PendingRequest pendingRequest = new
NetworkPartitionMetadataClient.PendingRequest(
node,
futures,
builder);
// Pass null as clientResponse.
- networkPartitionMetadataClient.handleResponse(pendingReqeust, null);
+ networkPartitionMetadataClient.handleResponse(pendingRequest, null);
assertTrue(partitionFuture.isDone() &&
!partitionFuture.isCompletedExceptionally());
PartitionMetadataClient.OffsetResponse response =
partitionFuture.get();
assertEquals(-1, response.offset());
@@ -326,11 +326,11 @@ class NetworkPartitionMetadataClientTest {
networkPartitionMetadataClient =
NetworkPartitionMetadataClientBuilder.builder().build();
Node node = mock(Node.class);
ListOffsetsRequest.Builder builder =
mock(ListOffsetsRequest.Builder.class);
- NetworkPartitionMetadataClient.PendingRequest pendingReqeust = new
NetworkPartitionMetadataClient.PendingRequest(
+ NetworkPartitionMetadataClient.PendingRequest pendingRequest = new
NetworkPartitionMetadataClient.PendingRequest(
node,
futures,
builder);
- networkPartitionMetadataClient.handleResponse(pendingReqeust,
clientResponse);
+ networkPartitionMetadataClient.handleResponse(pendingRequest,
clientResponse);
assertTrue(partitionFuture.isDone() &&
!partitionFuture.isCompletedExceptionally());
PartitionMetadataClient.OffsetResponse response =
partitionFuture.get();
assertEquals(-1, response.offset());
@@ -352,11 +352,11 @@ class NetworkPartitionMetadataClientTest {
networkPartitionMetadataClient =
NetworkPartitionMetadataClientBuilder.builder().build();
Node node = mock(Node.class);
ListOffsetsRequest.Builder builder =
mock(ListOffsetsRequest.Builder.class);
- NetworkPartitionMetadataClient.PendingRequest pendingReqeust = new
NetworkPartitionMetadataClient.PendingRequest(
+ NetworkPartitionMetadataClient.PendingRequest pendingRequest = new
NetworkPartitionMetadataClient.PendingRequest(
node,
futures,
builder);
- networkPartitionMetadataClient.handleResponse(pendingReqeust,
clientResponse);
+ networkPartitionMetadataClient.handleResponse(pendingRequest,
clientResponse);
assertTrue(partitionFuture.isDone() &&
!partitionFuture.isCompletedExceptionally());
PartitionMetadataClient.OffsetResponse response =
partitionFuture.get();
assertEquals(-1, response.offset());