diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/DefaultMessagePoller.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/DefaultMessagePoller.java
index 1bb906c6b..2507ecd07 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/DefaultMessagePoller.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/DefaultMessagePoller.java
@@ -353,7 +353,7 @@ public JoyQueueCode commitIndex(String topic, short partition, long index) {
         TopicMetadata topicMetadata = messagePollerInner.getAndCheckTopicMetadata(topic);
 
         PartitionMetadata partitionMetadata = topicMetadata.getPartition(partition);
-        Preconditions.checkArgument(partitionMetadata != null, "partition is not exist");
+        Preconditions.checkArgument(partitionMetadata != null, "partition dose not exist");
 
         return consumerIndexManager.commitIndex(topic, config.getAppFullName(), partition, index, config.getTimeout());
     }
@@ -426,4 +426,4 @@ protected void checkState() {
             throw new ConsumerException("consumer is not started", JoyQueueCode.CN_SERVICE_NOT_AVAILABLE.getCode());
         }
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/MessagePollerInner.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/MessagePollerInner.java
index b698a6086..75cdf4824 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/MessagePollerInner.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/MessagePollerInner.java
@@ -331,10 +331,10 @@ public BrokerAssignments buildAllBrokerAssignments(TopicMetadata topicMetadata)
     public TopicMetadata getAndCheckTopicMetadata(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(getTopicFullName(topic), config.getAppFullName());
         if (topicMetadata == null) {
-            throw new ConsumerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ConsumerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getConsumerPolicy() == null) {
-            throw new ConsumerException(String.format("topic %s consumer %s is not exist", topic, config.getAppFullName()), JoyQueueCode.FW_CONSUMER_NOT_EXISTS.getCode());
+            throw new ConsumerException(String.format("topic %s consumer %s dose not exist", topic, config.getAppFullName()), JoyQueueCode.FW_CONSUMER_NOT_EXISTS.getCode());
         }
         return topicMetadata;
     }
@@ -342,4 +342,4 @@ public TopicMetadata getAndCheckTopicMetadata(String topic) {
     public String getTopicFullName(String topic) {
         return NameServerHelper.getTopicFullName(topic, nameServerConfig);
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/PartitionMessagePoller.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/PartitionMessagePoller.java
index 94665f2cb..209a05eaf 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/PartitionMessagePoller.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/PartitionMessagePoller.java
@@ -344,7 +344,7 @@ public JoyQueueCode commitIndex(String topic, short partition, long index) {
         TopicMetadata topicMetadata = messagePollerInner.getAndCheckTopicMetadata(topic);
 
         PartitionMetadata partitionMetadata = topicMetadata.getPartition(partition);
-        Preconditions.checkArgument(partitionMetadata != null, "partition is not exist");
+        Preconditions.checkArgument(partitionMetadata != null, "partition dose not exist");
 
         return consumerIndexManager.commitIndex(topic, config.getAppFullName(), partition, index, config.getTimeout());
     }
@@ -426,4 +426,4 @@ protected void checkState() {
             throw new ConsumerException("consumer is not started", JoyQueueCode.CN_SERVICE_NOT_AVAILABLE.getCode());
         }
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/TopicMessageConsumer.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/TopicMessageConsumer.java
index 3925685f5..ad5594f6a 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/TopicMessageConsumer.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/consumer/support/TopicMessageConsumer.java
@@ -126,10 +126,10 @@ protected MessagePoller createMessagePoller(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(topicName.getFullName(), config.getAppFullName());
 
         if (topicMetadata == null) {
-            throw new ConsumerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ConsumerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getConsumerPolicy() == null) {
-            throw new ConsumerException(String.format("topic %s consumer %s is not exist", topic, config.getAppFullName()), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ConsumerException(String.format("topic %s consumer %s dose not exist", topic, config.getAppFullName()), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
 
         if (config.getThread() == ConsumerConfig.NONE_THREAD) {
@@ -177,4 +177,4 @@ public synchronized void removeListener(BaseMessageListener messageListener) {
     public MessagePoller getMessagePoller() {
         return messagePoller;
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/checker/ProduceMessageChecker.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/checker/ProduceMessageChecker.java
index 41a07fc51..f9566b068 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/checker/ProduceMessageChecker.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/checker/ProduceMessageChecker.java
@@ -43,7 +43,7 @@ public static void checkMessage(ProduceMessage produceMessage, ProducerConfig co
             throwCheckException("message body is not empty");
         }
         if (produceMessage.getPartition() != ProduceMessage.NONE_PARTITION && produceMessage.getPartition() < 0) {
-            throwCheckException("message body is not exist");
+            throwCheckException("message body dose not exist");
         }
         if (StringUtils.isNotBlank(produceMessage.getBody()) && produceMessage.getBody().length() > config.getBodyLengthLimit()) {
             throwCheckException(String.format("body is too long, it must less than %s characters", config.getBodyLengthLimit()));
@@ -92,4 +92,4 @@ public static void checkMessages(List<ProduceMessage> produceMessages, ProducerC
     protected static void throwCheckException(String message) {
         throw new ProducerException(message, JoyQueueCode.CN_PARAM_ERROR.getCode());
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/feedback/DefaultTxFeedbackManager.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/feedback/DefaultTxFeedbackManager.java
index 73dc39179..60cc805ad 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/feedback/DefaultTxFeedbackManager.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/feedback/DefaultTxFeedbackManager.java
@@ -118,7 +118,7 @@ public synchronized void removeTransactionCallback(String topic) {
 
         TxFeedbackScheduler txFeedbackScheduler = txCallback.get(topicFullName);
         if (txFeedbackScheduler == null) {
-            throw new IllegalArgumentException(String.format("%s feedback is not exist", topic));
+            throw new IllegalArgumentException(String.format("%s feedback dose not exist", topic));
         }
 
         if (txFeedbackScheduler.isStarted()) {
@@ -130,10 +130,10 @@ public synchronized void removeTransactionCallback(String topic) {
     protected TopicMetadata checkTopicMetadata(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(getTopicFullName(topic), config.getApp());
         if (topicMetadata == null) {
-            throw new ProducerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ProducerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getProducerPolicy() == null) {
-            throw new ProducerException(String.format("topic %s producer %s is not exist", topic, config.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
+            throw new ProducerException(String.format("topic %s producer %s dose not exist", topic, config.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
         }
         return topicMetadata;
     }
@@ -147,4 +147,4 @@ protected void checkState() {
             throw new UnsupportedOperationException("txFeedbackManager is not started");
         }
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/support/MessageProducerInner.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/support/MessageProducerInner.java
index 6cd2d753e..dd8e29d3e 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/support/MessageProducerInner.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/producer/support/MessageProducerInner.java
@@ -301,10 +301,10 @@ protected List<SendResult> handleSendBatchResultData(String topic, String app, S
     public TopicMetadata getAndCheckTopicMetadata(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(getTopicFullName(topic), config.getApp());
         if (topicMetadata == null) {
-            throw new ProducerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ProducerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getProducerPolicy() == null) {
-            throw new ProducerException(String.format("topic %s producer %s is not exist", topic, nameServerConfig.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
+            throw new ProducerException(String.format("topic %s producer %s dose not exist", topic, nameServerConfig.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
         }
         return topicMetadata;
     }
@@ -392,4 +392,4 @@ public PartitionMetadata dispatchPartitions(List<ProduceMessage> messages, Topic
     public boolean isFailover(List<ProduceMessage> messages) {
         return (messages.get(0).getPartition() == ProduceMessage.NONE_PARTITION);
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/support/DefaultMessageAccessPoint.java b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/support/DefaultMessageAccessPoint.java
index 669440eb7..0d635fa12 100644
--- a/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/support/DefaultMessageAccessPoint.java
+++ b/joyqueue-client/joyqueue-client-core/src/main/java/org/joyqueue/client/internal/support/DefaultMessageAccessPoint.java
@@ -172,7 +172,7 @@ public synchronized void removeTransactionCallback(String topic) {
         Preconditions.checkArgument(StringUtils.isNotBlank(topic), "topic can not be null");
         TxFeedbackManager txFeedbackManager = txFeedbackManagerMap.get(topic);
         if (txFeedbackManager == null) {
-            throw new IllegalArgumentException(String.format("%s feedback is not exist", topic));
+            throw new IllegalArgumentException(String.format("%s feedback dose not exist", topic));
         }
         txFeedbackManager.removeTransactionCallback(topic);
     }
@@ -242,4 +242,4 @@ protected TxFeedbackManager getTxFeedbackManager(TxFeedbackConfig config) {
         }
         return txFeedbackManager;
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java
index 5b30f7532..f994b4a3e 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java
@@ -342,7 +342,7 @@ public Topic createTopic(Topic topic, List<Broker> select, Identity operator) th
     public void removeTopic(String namespace, String topicCode) throws Exception {
         Topic topic = topicService.findByCode(namespace, topicCode);
         if (topic == null) {
-            throw new BusinessException("topic is not exist");
+            throw new BusinessException("topic dose not exist");
         }
         topicService.delete(topic);
     }
diff --git a/joyqueue-server/joyqueue-broker-core/src/main/java/org/joyqueue/broker/cluster/ClusterManager.java b/joyqueue-server/joyqueue-broker-core/src/main/java/org/joyqueue/broker/cluster/ClusterManager.java
index 25165fc3b..4538317f8 100644
--- a/joyqueue-server/joyqueue-broker-core/src/main/java/org/joyqueue/broker/cluster/ClusterManager.java
+++ b/joyqueue-server/joyqueue-broker-core/src/main/java/org/joyqueue/broker/cluster/ClusterManager.java
@@ -1096,7 +1096,7 @@ protected Consumer buildConsumeCache(Consumer consumer) {
 
         protected Consumer getConsumerByTopicAndApp(TopicName topic, String app) {
             if (!consumerCache.containsKey(topic.getFullName())) {
-                logger.warn("topic {} is not exist on this broker", topic.getFullName());
+                logger.warn("topic {} dose not exist on this broker", topic.getFullName());
                 return null;
             }
             CacheConsumer consumer = consumerCache.get(topic.getFullName()).get(app);
@@ -1110,7 +1110,7 @@ protected Consumer getConsumerByTopicAndApp(TopicName topic, String app) {
 
         protected Producer getProducerByTopicAndApp(TopicName topic, String app) {
             if (!producerCache.containsKey(topic.getFullName())) {
-                logger.warn("topic {} is not exist on this broker", topic.getFullName());
+                logger.warn("topic {} dose not exist on this broker", topic.getFullName());
                 return null;
             }
             CacheProducer producer = producerCache.get(topic.getFullName()).get(app);
@@ -1512,4 +1512,4 @@ protected void doStop() {
         }
         logger.info("clusterManager is stopped");
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddConsumerRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddConsumerRequestHandler.java
index 3dd60a5a7..a08eccf40 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddConsumerRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddConsumerRequestHandler.java
@@ -63,7 +63,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(addConsumerRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}", transport);
+            logger.warn("connection dose not exist, transport: {}", transport);
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -110,4 +110,4 @@ protected String generateConsumerId(Connection connection, String topic, String
     public int type() {
         return JoyQueueCommandType.ADD_CONSUMER_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddProducerRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddProducerRequestHandler.java
index 927dfb586..9672ac455 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddProducerRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/AddProducerRequestHandler.java
@@ -63,7 +63,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(addProducerRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, addProducerRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, addProducerRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -110,4 +110,4 @@ protected String generateProducerId(Connection connection, String topic, String
     public int type() {
         return JoyQueueCommandType.ADD_PRODUCER_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitAckRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitAckRequestHandler.java
index fc85bb8fb..322004d02 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitAckRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitAckRequestHandler.java
@@ -86,7 +86,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(commitAckRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, commitAckRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, commitAckRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -249,4 +249,4 @@ private RetryMessageModel generateRetryMessage(Consumer consumer, BrokerMessage
     public int type() {
         return JoyQueueCommandType.COMMIT_ACK_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitIndexRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitIndexRequestHandler.java
index 0c92cbc53..8cf083aae 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitIndexRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitIndexRequestHandler.java
@@ -51,7 +51,7 @@ public Command handle(Transport transport, Command command) {
         String app = commitIndexRequest.getApp();
 
         if (connection == null || !connection.isAuthorized(app)) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, app);
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, app);
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -99,4 +99,4 @@ public Command handle(Transport transport, Command command) {
     public int type() {
         return JoyQueueCommandType.COMMIT_ACK_INDEX_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchAssignedPartitionRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchAssignedPartitionRequestHandler.java
index 28cb969b9..7a103ad2b 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchAssignedPartitionRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchAssignedPartitionRequestHandler.java
@@ -81,7 +81,7 @@ public Command handle(Transport transport, Command command) {
         String connectionId = ((InetSocketAddress) transport.remoteAddress()).getHostString();
 
         if (connection == null || !connection.isAuthorized(fetchAssignedPartitionRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchAssignedPartitionRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchAssignedPartitionRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -146,4 +146,4 @@ protected List<PartitionGroup> getTopicRegionPartitionGroup(TopicConfig topicCon
     public int type() {
         return JoyQueueCommandType.FETCH_ASSIGNED_PARTITION_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchClusterRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchClusterRequestHandler.java
index 4e6f4a7ce..3ba585e05 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchClusterRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchClusterRequestHandler.java
@@ -79,7 +79,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchClusterRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchClusterRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchClusterRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -198,4 +198,4 @@ protected TopicPartition convertTopicPartition(PartitionGroup partitionGroup, sh
     public int type() {
         return JoyQueueCommandType.FETCH_CLUSTER_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchIndexRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchIndexRequestHandler.java
index c977e75e6..642fb351b 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchIndexRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchIndexRequestHandler.java
@@ -62,7 +62,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchIndexRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchIndexRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchIndexRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -103,4 +103,4 @@ protected FetchIndexData fetchIndex(Connection connection, Consumer consumer, sh
     public int type() {
         return JoyQueueCommandType.FETCH_INDEX_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchPartitionMessageRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchPartitionMessageRequestHandler.java
index ded080c2f..590ce2f58 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchPartitionMessageRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchPartitionMessageRequestHandler.java
@@ -74,7 +74,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchPartitionMessageRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchPartitionMessageRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchPartitionMessageRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -157,4 +157,4 @@ protected FetchPartitionMessageAckData fetchMessage(Transport transport, Consume
     public int type() {
         return JoyQueueCommandType.FETCH_PARTITION_MESSAGE_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchProduceFeedbackRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchProduceFeedbackRequestHandler.java
index 41282f963..585d9abaf 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchProduceFeedbackRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchProduceFeedbackRequestHandler.java
@@ -70,7 +70,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchProduceFeedbackRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchProduceFeedbackRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchProduceFeedbackRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -117,4 +117,4 @@ protected List<FetchProduceFeedbackAckData> buildFeedbackAckData(List<Transactio
     public int type() {
         return JoyQueueCommandType.FETCH_PRODUCE_FEEDBACK_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchTopicMessageRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchTopicMessageRequestHandler.java
index ab91d7a10..4df4ff064 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchTopicMessageRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchTopicMessageRequestHandler.java
@@ -82,7 +82,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchTopicMessageRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
+            logger.warn("connection dose not exist, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -108,7 +108,7 @@ public Command handle(Transport transport, Command command) {
             Consumer consumer = (StringUtils.isBlank(consumerId) ? null : sessionManager.getConsumerById(consumerId));
 
             if (consumer == null) {
-                logger.warn("connection is not exists, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
+                logger.warn("connection dose not exist, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
                 result.put(topic, new FetchTopicMessageAckData(CheckResultConverter.convertFetchCode(command.getHeader().getVersion(), JoyQueueCode.FW_CONSUMER_NOT_EXISTS)));
                 continue;
             }
@@ -157,4 +157,4 @@ protected FetchTopicMessageAckData fetchMessage(Transport transport, Consumer co
     public int type() {
         return JoyQueueCommandType.FETCH_TOPIC_MESSAGE_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FindCoordinatorRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FindCoordinatorRequestHandler.java
index fdd318a59..a86863553 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FindCoordinatorRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/FindCoordinatorRequestHandler.java
@@ -67,7 +67,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(findCoordinatorRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, findCoordinatorRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, findCoordinatorRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -103,4 +103,4 @@ protected Map<String, FindCoordinatorAckData> findCoordinators(Connection connec
     public int type() {
         return JoyQueueCommandType.FIND_COORDINATOR_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageCommitRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageCommitRequestHandler.java
index 77a283a8b..5aeeaeb80 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageCommitRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageCommitRequestHandler.java
@@ -66,7 +66,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(produceMessageCommitRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, produceMessageCommitRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, produceMessageCommitRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -107,4 +107,4 @@ protected ProduceMessageCommitResponse produceMessageCommit(Connection connectio
     public int type() {
         return JoyQueueCommandType.PRODUCE_MESSAGE_COMMIT_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessagePrepareRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessagePrepareRequestHandler.java
index 9b4ba2ae4..9932004ac 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessagePrepareRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessagePrepareRequestHandler.java
@@ -72,14 +72,14 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(produceMessagePrepareRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, produceMessagePrepareRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, produceMessagePrepareRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
         String producerId = connection.getProducer(produceMessagePrepareRequest.getTopic(), produceMessagePrepareRequest.getApp());
         Producer producer = (StringUtils.isBlank(producerId) ? null : sessionManager.getProducerById(producerId));
         if (producer == null) {
-            logger.warn("producer is not exists, transport: {}", transport);
+            logger.warn("producer dose not exist, transport: {}", transport);
             return BooleanAck.build(JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
         }
 
@@ -121,4 +121,4 @@ protected ProduceMessagePrepareResponse produceMessagePrepare(Producer producer,
     public int type() {
         return JoyQueueCommandType.PRODUCE_MESSAGE_PREPARE_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRequestHandler.java
index 961dea424..76c1163ed 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRequestHandler.java
@@ -89,7 +89,7 @@ public Command handle(Transport transport, Command request) {
         String app = produceMessageRequest.getApp();
 
         if (connection == null || !connection.isAuthorized(app)) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, app);
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, app);
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -255,4 +255,4 @@ protected ProduceMessageAckData buildResponse(ProduceMessageData produceMessageD
     public int type() {
         return JoyQueueCommandType.PRODUCE_MESSAGE_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRollbackRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRollbackRequestHandler.java
index 875e05e91..dc7d390d9 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRollbackRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/ProduceMessageRollbackRequestHandler.java
@@ -64,7 +64,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(produceMessageRollbackRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, produceMessageRollbackRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, produceMessageRollbackRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -105,4 +105,4 @@ protected ProduceMessageRollbackResponse produceMessageRollback(Connection conne
     public int type() {
         return JoyQueueCommandType.PRODUCE_MESSAGE_ROLLBACK_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveConsumerRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveConsumerRequestHandler.java
index 709eb87b6..ee824445d 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveConsumerRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveConsumerRequestHandler.java
@@ -55,7 +55,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(removeConsumerRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, removeConsumerRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, removeConsumerRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -74,4 +74,4 @@ public Command handle(Transport transport, Command command) {
     public int type() {
         return JoyQueueCommandType.REMOVE_CONSUMER_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveProducerRequestHandler.java b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveProducerRequestHandler.java
index a80dbee37..68c0075d6 100644
--- a/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveProducerRequestHandler.java
+++ b/joyqueue-server/joyqueue-broker-protocol/src/main/java/org/joyqueue/broker/protocol/handler/RemoveProducerRequestHandler.java
@@ -55,7 +55,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(removeProducerRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, removeProducerRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, removeProducerRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -74,4 +74,4 @@ public Command handle(Transport transport, Command command) {
     public int type() {
         return JoyQueueCommandType.REMOVE_PRODUCER_REQUEST.getCode();
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/nameservice/NameServerInternal.java b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/nameservice/NameServerInternal.java
index 47dab107d..0caf8112c 100644
--- a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/nameservice/NameServerInternal.java
+++ b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/nameservice/NameServerInternal.java
@@ -263,7 +263,7 @@ public void leaderReport(TopicName topic, int partitionGroup, int leaderBrokerId
             }
         }
         if (null == group) {
-            throw new RuntimeException(String.format("topic[%s] group[%s] is not exist", topic, partitionGroup));
+            throw new RuntimeException(String.format("topic[%s] group[%s] dose not exist", topic, partitionGroup));
         }
         group.setIsrs(isrId);
         group.setLeader(leaderBrokerId);
diff --git a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultBrokerService.java b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultBrokerService.java
index 6406657e3..fabe3aec5 100644
--- a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultBrokerService.java
+++ b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultBrokerService.java
@@ -92,7 +92,7 @@ public Broker add(Broker broker) {
     public Broker update(Broker broker) {
         Broker oldBroker = brokerInternalService.getById(broker.getId());
         if (oldBroker == null) {
-            throw new NsrException(String.format("broker: %s is not exist", broker.getId()));
+            throw new NsrException(String.format("broker: %s dose not exist", broker.getId()));
         }
 
         try {
@@ -123,4 +123,4 @@ public Broker update(Broker broker) {
     public void delete(int id) {
         brokerInternalService.delete(id);
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultConsumerService.java b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultConsumerService.java
index caf4279f7..504b04476 100644
--- a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultConsumerService.java
+++ b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultConsumerService.java
@@ -97,7 +97,7 @@ public List<Consumer> getAll() {
     @Override
     public Consumer add(Consumer consumer) {
         if (topicInternalService.getTopicByCode(consumer.getTopic().getNamespace(), consumer.getTopic().getCode()) == null) {
-            throw new NsrException(String.format("topic: %s is not exist", consumer.getTopic()));
+            throw new NsrException(String.format("topic: %s dose not exist", consumer.getTopic()));
         }
         if (consumerInternalService.getByTopicAndApp(consumer.getTopic(), consumer.getApp()) != null) {
             throw new NsrException(String.format("consumer: %s,%s is exist", consumer.getTopic(), consumer.getApp()));
@@ -134,7 +134,7 @@ public Consumer add(Consumer consumer) {
     public Consumer update(Consumer consumer) {
         Consumer oldConsumer = consumerInternalService.getByTopicAndApp(consumer.getTopic(), consumer.getApp());
         if (oldConsumer == null) {
-            throw new NsrException(String.format("topic: %s, consumer: %s is not exist", oldConsumer.getTopic(), oldConsumer.getApp()));
+            throw new NsrException(String.format("topic: %s, consumer: %s dose not exist", oldConsumer.getTopic(), oldConsumer.getApp()));
         }
 
         logger.info("updateConsumer, topic: {}, app: {}", consumer.getTopic(), consumer.getApp());
@@ -168,7 +168,7 @@ public Consumer update(Consumer consumer) {
     public void delete(String id) {
         Consumer consumer = consumerInternalService.getById(id);
         if (consumer == null) {
-            throw new NsrException(String.format("consumer: %s is not exist", id));
+            throw new NsrException(String.format("consumer: %s dose not exist", id));
         }
 
         logger.info("deleteConsumer, topic: {}, app: {}", consumer.getTopic(), consumer.getApp());
@@ -212,4 +212,4 @@ protected List<Broker> getReplicas(List<PartitionGroup> partitionGroups) {
         }
         return brokerInternalService.getByIds(Lists.newArrayList(replicaIds));
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultProducerService.java b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultProducerService.java
index 95c144c0d..0c89b97e6 100644
--- a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultProducerService.java
+++ b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultProducerService.java
@@ -97,10 +97,10 @@ public List<Producer> getAll() {
     @Override
     public Producer add(Producer producer) {
         if (topicInternalService.getTopicByCode(producer.getTopic().getNamespace(), producer.getTopic().getCode()) == null) {
-            throw new NsrException(String.format("topic: %s is not exist", producer.getTopic()));
+            throw new NsrException(String.format("topic: %s dose not exist", producer.getTopic()));
         }
         if (producerInternalService.getByTopicAndApp(producer.getTopic(), producer.getApp()) != null) {
-            throw new NsrException(String.format("producer: %s,%s is not exist", producer.getTopic(), producer.getApp()));
+            throw new NsrException(String.format("producer: %s,%s dose not exist", producer.getTopic(), producer.getApp()));
         }
 
         logger.info("addProducer, topic: {}, app: {}", producer.getTopic(), producer.getApp());
@@ -134,7 +134,7 @@ public Producer add(Producer producer) {
     public Producer update(Producer producer) {
         Producer oldProducer = producerInternalService.getByTopicAndApp(producer.getTopic(), producer.getApp());
         if (oldProducer == null) {
-            throw new NsrException(String.format("topic: %s, producer: %s is not exist", producer.getTopic(), producer.getApp()));
+            throw new NsrException(String.format("topic: %s, producer: %s dose not exist", producer.getTopic(), producer.getApp()));
         }
 
         logger.info("updateProducer, topic: {}, app: {}", producer.getTopic(), producer.getApp());
@@ -168,7 +168,7 @@ public Producer update(Producer producer) {
     public void delete(String id) {
         Producer producer = producerInternalService.getById(id);
         if (producer == null) {
-            throw new NsrException(String.format("producer: %s is not exist", id));
+            throw new NsrException(String.format("producer: %s dose not exist", id));
         }
 
         logger.info("deleteProducer, topic: {}, app: {}", producer.getTopic(), producer.getApp());
@@ -212,4 +212,4 @@ protected List<Broker> getReplicas(List<PartitionGroup> partitionGroups) {
         }
         return brokerInternalService.getByIds(Lists.newArrayList(replicaIds));
     }
-}
\ No newline at end of file
+}
diff --git a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultTopicService.java b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultTopicService.java
index 28c60abc4..9b7837e32 100644
--- a/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultTopicService.java
+++ b/joyqueue-server/joyqueue-nsr/joyqueue-nsr-core/src/main/java/org/joyqueue/nsr/support/DefaultTopicService.java
@@ -142,7 +142,7 @@ public void addTopic(Topic topic, List<PartitionGroup> partitionGroups) {
     public void removeTopic(Topic topic) {
         topic = topicInternalService.getTopicByCode(topic.getName().getNamespace(), topic.getName().getCode());
         if (topic == null) {
-            throw new NsrException(String.format("topic: %s is not exist", topic.getName()));
+            throw new NsrException(String.format("topic: %s dose not exist", topic.getName()));
         }
 
         logger.info("removeTopic, topic: {}", topic);
@@ -175,10 +175,10 @@ public void removeTopic(Topic topic) {
     @Override
     public void addPartitionGroup(PartitionGroup partitionGroup) {
         if (topicInternalService.getTopicByCode(partitionGroup.getTopic().getNamespace(), partitionGroup.getTopic().getCode()) == null) {
-            throw new NsrException(String.format("topic: %s is not exist", partitionGroup.getTopic()));
+            throw new NsrException(String.format("topic: %s dose not exist", partitionGroup.getTopic()));
         }
         if (partitionGroupInternalService.getByTopicAndGroup(partitionGroup.getTopic(), partitionGroup.getGroup()) != null) {
-            throw new NsrException(String.format("topic: %s, group: %s is not exist", partitionGroup.getTopic(), partitionGroup.getGroup()));
+            throw new NsrException(String.format("topic: %s, group: %s dose not exist", partitionGroup.getTopic(), partitionGroup.getGroup()));
         }
 
         logger.info("addPartitionGroup, topic: {}, partitionGroup: {}", partitionGroup.getTopic(), partitionGroup);
@@ -214,12 +214,12 @@ public void addPartitionGroup(PartitionGroup partitionGroup) {
     @Override
     public void removePartitionGroup(PartitionGroup partitionGroup) {
         if (topicInternalService.getTopicByCode(partitionGroup.getTopic().getNamespace(), partitionGroup.getTopic().getCode()) == null) {
-            throw new NsrException(String.format("topic: %s is not exist", partitionGroup.getTopic()));
+            throw new NsrException(String.format("topic: %s dose not exist", partitionGroup.getTopic()));
         }
 
         PartitionGroup oldPartitionGroup = partitionGroupInternalService.getByTopicAndGroup(partitionGroup.getTopic(), partitionGroup.getGroup());
         if (oldPartitionGroup == null) {
-            throw new NsrException(String.format("topic: %s, group: %s is not exist", partitionGroup.getTopic(), partitionGroup.getGroup()));
+            throw new NsrException(String.format("topic: %s, group: %s dose not exist", partitionGroup.getTopic(), partitionGroup.getGroup()));
         }
 
         logger.info("removePartitionGroup, topic: {}, partitionGroup: {}", partitionGroup.getTopic(), partitionGroup);
@@ -252,7 +252,7 @@ public void removePartitionGroup(PartitionGroup partitionGroup) {
     public Collection<Integer> updatePartitionGroup(PartitionGroup partitionGroup) {
         Topic oldTopic = topicInternalService.getTopicByCode(partitionGroup.getTopic().getNamespace(), partitionGroup.getTopic().getCode());
         if (oldTopic == null) {
-            throw new NsrException(String.format("topic: %s is not exist", partitionGroup.getTopic()));
+            throw new NsrException(String.format("topic: %s dose not exist", partitionGroup.getTopic()));
         }
 
         PartitionGroup oldPartitionGroup = partitionGroupInternalService.getByTopicAndGroup(partitionGroup.getTopic(), partitionGroup.getGroup());
@@ -306,7 +306,7 @@ public Collection<Integer> updatePartitionGroup(PartitionGroup partitionGroup) {
     public void leaderReport(PartitionGroup group) {
         PartitionGroup oldPartitionGroup = partitionGroupInternalService.getById(group.getId());
         if (oldPartitionGroup == null) {
-            throw new NsrException(String.format("topic: %s, group: %s is not exist", oldPartitionGroup.getTopic(), oldPartitionGroup.getGroup()));
+            throw new NsrException(String.format("topic: %s, group: %s dose not exist", oldPartitionGroup.getTopic(), oldPartitionGroup.getGroup()));
         }
 
         if (oldPartitionGroup.getLeader().equals(group.getLeader()) && oldPartitionGroup.getTerm().equals(group.getTerm())) {
@@ -347,23 +347,23 @@ public void leaderReport(PartitionGroup group) {
     @Override
     public void leaderChange(PartitionGroup group) {
         if (topicInternalService.getTopicByCode(group.getTopic().getNamespace(), group.getTopic().getCode()) == null) {
-            throw new NsrException(String.format("topic: %s is not exist", group.getTopic()));
+            throw new NsrException(String.format("topic: %s dose not exist", group.getTopic()));
         }
 
         PartitionGroup oldPartitionGroup = partitionGroupInternalService.getByTopicAndGroup(group.getTopic(), group.getGroup());
         if (oldPartitionGroup == null) {
-            throw new NsrException(String.format("topic: %s, group: %s is not exist", group.getTopic(), group.getGroup()));
+            throw new NsrException(String.format("topic: %s, group: %s dose not exist", group.getTopic(), group.getGroup()));
         }
 
         Broker leader = brokerInternalService.getById(group.getLeader());
         if (leader == null) {
-            throw new NsrException(String.format("topic: %s, group: %s, broker: {} is not exist", group.getTopic(), group.getGroup(), group.getLeader()));
+            throw new NsrException(String.format("topic: %s, group: %s, broker: {} dose not exist", group.getTopic(), group.getGroup(), group.getLeader()));
         }
 
         logger.info("leaderChange, topic: {}, partitionGroup: {}", group.getTopic(), group);
         Broker oldLeader = brokerInternalService.getById(oldPartitionGroup.getLeader());
         if (oldLeader == null) {
-            throw new NsrException(String.format("topic: %s, group: %s, broker: {} is not exist", group.getTopic(), group.getGroup(), group.getLeader()));
+            throw new NsrException(String.format("topic: %s, group: %s, broker: {} dose not exist", group.getTopic(), group.getGroup(), group.getLeader()));
         }
 
         try {
@@ -396,7 +396,7 @@ public List<PartitionGroup> getPartitionGroup(String namespace, String topic, Ob
     public Topic update(Topic topic) {
         Topic oldTopic = topicInternalService.getTopicByCode(topic.getName().getNamespace(), topic.getName().getCode());
         if (oldTopic == null) {
-            throw new NsrException(String.format("topic: %s is not exist", topic.getName()));
+            throw new NsrException(String.format("topic: %s dose not exist", topic.getName()));
         }
 
         logger.info("update, topic: {}", topic);