root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix typo in AssignmentsManager (#20059)
CI / build (push) Waiting to run Details 

Disonnected -> Disconnected

Reviewers: Jhen-Yung Hsu <jhenyunghsu@gmail.com>, Chia-Ping Tsai
 <chia7712@gmail.com>
This commit is contained in:
Dmitry Werner 2025-06-29 22:30:25 +05:00 committed by GitHub
parent bd14ed21b4
commit 21e97e3c10
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/main/java/org/apache/kafka/server/AssignmentsManager.java
View File

@ -435,7 +435,7 @@ public final class AssignmentsManager {
return Optional.of("AuthenticationException"); return Optional.of("AuthenticationException");
} }
if (response.get().wasTimedOut()) { if (response.get().wasTimedOut()) {
return Optional.of("Disonnected[Timeout]"); return Optional.of("Disconnected[Timeout]");
} }
if (response.get().wasDisconnected()) { if (response.get().wasDisconnected()) {
return Optional.of("Disconnected"); return Optional.of("Disconnected");

2
server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java
View File

@ -425,7 +425,7 @@ public class AssignmentsManagerTest {
@Test @Test
public void testGlobalResponseErrorDisconnectedTimedOut() { public void testGlobalResponseErrorDisconnectedTimedOut() {
assertEquals(Optional.of("Disonnected[Timeout]"), assertEquals(Optional.of("Disconnected[Timeout]"),
AssignmentsManager.globalResponseError(Optional.of( AssignmentsManager.globalResponseError(Optional.of(
new ClientResponse(null, null, "", 0, 0, true, true, new ClientResponse(null, null, "", 0, 0, true, true,
null, null, null)))); null, null, null))));