diff --git a/naming/src/main/java/com/alibaba/nacos/naming/consistency/persistent/impl/BasePersistentServiceProcessor.java b/naming/src/main/java/com/alibaba/nacos/naming/consistency/persistent/impl/BasePersistentServiceProcessor.java index 43f4a31c7ac..83564c9c07a 100644 --- a/naming/src/main/java/com/alibaba/nacos/naming/consistency/persistent/impl/BasePersistentServiceProcessor.java +++ b/naming/src/main/java/com/alibaba/nacos/naming/consistency/persistent/impl/BasePersistentServiceProcessor.java @@ -163,7 +163,13 @@ public Response onRequest(ReadRequest request) { public Response onApply(WriteRequest request) { final byte[] data = request.getData().toByteArray(); final BatchWriteRequest bwRequest = serializer.deserialize(data, BatchWriteRequest.class); - final Op op = Op.valueOf(request.getOperation()); + final Op op; + try { + op = Op.valueOf(request.getOperation()); + } catch (Exception e) { + Loggers.RAFT.error("unsupport operation: {}, request: {}", request.getOperation(), request, e); + return Response.newBuilder().setSuccess(false).setErrMsg("unsupport operation : " + request.getOperation()).build(); + } final Lock lock = readLock; lock.lock(); try {