Update GroupCoordinator

streamnative · Dec 2, 2022 · de820da · de820da
1 parent c3e5610
commit de820da
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupCoordinator.java b/...src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupCoordinator.java
@@ -563,7 +563,7 @@ public CompletableFuture<Errors> handleLeaveGroup(
         return validateGroupStatus(groupId, ApiKeys.LEAVE_GROUP).map(CompletableFuture::completedFuture
         ).orElseGet(() -> groupManager.getGroup(groupId).map(group -> group.inLock(() -> {
             if (group.is(Dead)) {
-                return CompletableFuture.completedFuture(Errors.UNKNOWN_MEMBER_ID);
+                return CompletableFuture.completedFuture(Errors.COORDINATOR_NOT_AVAILABLE);
             } else if (!members.stream().allMatch(group::has)) {
                 return CompletableFuture.completedFuture(Errors.UNKNOWN_MEMBER_ID);
             } else {