diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java index 8bf48acc4dd1afb96bdebbb90d4ed009cb2e24b4..e35316d603dfccd9b0902e8b564cd7912bed8235 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java @@ -220,6 +220,7 @@ public class AdminBrokerProcessor implements NettyRequestProcessor { response.setRemark(null); ctx.writeAndFlush(response); } catch (Exception e) { + log.error("Failed to produce a proper response", e); } TopicConfig topicConfig = new TopicConfig(requestHeader.getTopic()); @@ -231,6 +232,7 @@ public class AdminBrokerProcessor implements NettyRequestProcessor { this.brokerController.getTopicConfigManager().updateTopicConfig(topicConfig); this.brokerController.registerBrokerAll(false, true); + return null; }