修复producer，consumer配置接口多处调用被覆盖的bug

jd-opensource · Sep 27, 2020 · 460f7ed · 460f7ed
1 parent 6391e53
commit 460f7ed
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...b-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ConsumerCommand.java b/...b-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ConsumerCommand.java
@@ -160,6 +160,7 @@ public Response configAddOrUpdate(@Body ConsumerConfig config) throws Exception
     private void mergeConsumerConfig(Consumer consumer, ConsumerConfig config) {
         if (consumer.getConfig() == null) {
             consumer.setConfig(config);
+            return;
         }
         if (config.getAckTimeout() !=null) {
             consumer.getConfig().setAckTimeout(config.getAckTimeout());