diff --git a/server/src/main/java/org/apache/kafka/server/AssignmentsManager.java b/server/src/main/java/org/apache/kafka/server/AssignmentsManager.java index 6d493d96ec1..5b20e1475a2 100644 --- a/server/src/main/java/org/apache/kafka/server/AssignmentsManager.java +++ b/server/src/main/java/org/apache/kafka/server/AssignmentsManager.java @@ -435,7 +435,7 @@ public final class AssignmentsManager { return Optional.of("AuthenticationException"); } if (response.get().wasTimedOut()) { - return Optional.of("Disonnected[Timeout]"); + return Optional.of("Disconnected[Timeout]"); } if (response.get().wasDisconnected()) { return Optional.of("Disconnected"); diff --git a/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java b/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java index 6644bccd230..3397a7488ff 100644 --- a/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java +++ b/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java @@ -425,7 +425,7 @@ public class AssignmentsManagerTest { @Test public void testGlobalResponseErrorDisconnectedTimedOut() { - assertEquals(Optional.of("Disonnected[Timeout]"), + assertEquals(Optional.of("Disconnected[Timeout]"), AssignmentsManager.globalResponseError(Optional.of( new ClientResponse(null, null, "", 0, 0, true, true, null, null, null))));