diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ConsumerConfig.java b/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ConsumerConfig.java
index 56095ae28..250d197c8 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ConsumerConfig.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ConsumerConfig.java
@@ -30,28 +30,28 @@ public class ConsumerConfig extends BaseNsrModel {
     /**
      * 开启就近机房消费
      **/
-    private boolean nearBy;
+    private Boolean nearBy;
 
     /**
      * 是否暂停消费
      **/
-    private boolean paused;
+    private Boolean paused;
 
     /**
      * 是否需要归档,默认不归档
      **/
-    private boolean archive;
+    private Boolean archive;
 
     /**
      * 是否启用重试服务，默认开启
      **/
-    private boolean retry = true;
+    private Boolean retry = true;
 
     /**
      * 延迟时间,最大延迟1小时
      */
     @Max(3600000)
-    private int delay = 0;
+    private Integer delay = 0;
 
     /**
      * 偏移量管理类型
@@ -62,56 +62,56 @@ public class ConsumerConfig extends BaseNsrModel {
      * 应答超时时间，默认2min
      */
     @Min(0)
-    private int ackTimeout = 120000;
+    private Integer ackTimeout = 120000;
 
     /**
      * 批量大小,默认10
      **/
     @Min(0)
     @Max(127)
-    private int batchSize = 10;
+    private Integer batchSize = 10;
 
     /**
      * 最大重试次数(无限制)
      **/
     @Min(0)
-    private int maxRetrys;
+    private Integer maxRetrys;
 
     /**
      * 最大重试间隔(默认5分钟)
      **/
     @Min(0)
-    private int maxRetryDelay;
+    private Integer maxRetryDelay;
 
     /**
      * 重试间隔
      */
     @Min(0)
-    private int retryDelay;
+    private Integer retryDelay;
 
     private String region;
 
     /**
      * 指数增加间隔时间
      **/
-    private boolean useExponentialBackOff = true;
+    private Boolean useExponentialBackOff = true;
 
     /**
      * 指数系数
      */
     @Min(0)
-    private double backOffMultiplier;
+    private Double backOffMultiplier;
 
     /**
      * 过期时间（默认3天）
      **/
     @Min(0)
-    private int expireTime;
+    private Integer expireTime;
 
     /**
      * 单队列并行度
      **/
-    private int concurrent = 1;
+    private Integer concurrent = 1;
 
     /**
      * 黑名单
@@ -120,14 +120,14 @@ public class ConsumerConfig extends BaseNsrModel {
 
     private String filters;
 
-    private int limitTps;
+    private Integer limitTps;
 
-    private int limitTraffic;
+    private Integer limitTraffic;
 
     private Map<String, String> params;
 
 
-    public boolean isNearBy() {
+    public Boolean isNearBy() {
         return nearBy;
     }
 
@@ -143,7 +143,7 @@ public void setConsumerId(String consumerId) {
         this.consumerId = consumerId;
     }
 
-    public boolean isPaused() {
+    public Boolean isPaused() {
         return paused;
     }
 
@@ -151,7 +151,7 @@ public void setPaused(boolean paused) {
         this.paused = paused;
     }
 
-    public boolean isArchive() {
+    public Boolean isArchive() {
         return archive;
     }
 
@@ -159,7 +159,7 @@ public void setArchive(boolean archive) {
         this.archive = archive;
     }
 
-    public boolean isRetry() {
+    public Boolean isRetry() {
         return retry;
     }
 
@@ -167,7 +167,7 @@ public void setRetry(boolean retry) {
         this.retry = retry;
     }
 
-    public int getDelay() {
+    public Integer getDelay() {
         return delay;
     }
 
@@ -175,7 +175,7 @@ public void setDelay(int delay) {
         this.delay = delay;
     }
 
-    public int getAckTimeout() {
+    public Integer getAckTimeout() {
         return ackTimeout;
     }
 
@@ -183,7 +183,7 @@ public void setAckTimeout(int ackTimeout) {
         this.ackTimeout = ackTimeout;
     }
 
-    public int getBatchSize() {
+    public Integer getBatchSize() {
         return batchSize;
     }
 
@@ -191,7 +191,7 @@ public void setBatchSize(int batchSize) {
         this.batchSize = batchSize;
     }
 
-    public int getMaxRetrys() {
+    public Integer getMaxRetrys() {
         return maxRetrys;
     }
 
@@ -199,7 +199,7 @@ public void setMaxRetrys(int maxRetrys) {
         this.maxRetrys = maxRetrys;
     }
 
-    public int getMaxRetryDelay() {
+    public Integer getMaxRetryDelay() {
         return maxRetryDelay;
     }
 
@@ -207,7 +207,7 @@ public void setMaxRetryDelay(int maxRetryDelay) {
         this.maxRetryDelay = maxRetryDelay;
     }
 
-    public int getRetryDelay() {
+    public Integer getRetryDelay() {
         return retryDelay;
     }
 
@@ -215,7 +215,7 @@ public void setRetryDelay(int retryDelay) {
         this.retryDelay = retryDelay;
     }
 
-    public boolean isUseExponentialBackOff() {
+    public Boolean isUseExponentialBackOff() {
         return useExponentialBackOff;
     }
 
@@ -223,7 +223,7 @@ public void setUseExponentialBackOff(boolean useExponentialBackOff) {
         this.useExponentialBackOff = useExponentialBackOff;
     }
 
-    public double getBackOffMultiplier() {
+    public Double getBackOffMultiplier() {
         return backOffMultiplier;
     }
 
@@ -231,7 +231,7 @@ public void setBackOffMultiplier(double backOffMultiplier) {
         this.backOffMultiplier = backOffMultiplier;
     }
 
-    public int getExpireTime() {
+    public Integer getExpireTime() {
         return expireTime;
     }
 
@@ -239,7 +239,7 @@ public void setExpireTime(int expireTime) {
         this.expireTime = expireTime;
     }
 
-    public int getConcurrent() {
+    public Integer getConcurrent() {
         return concurrent;
     }
 
@@ -267,7 +267,7 @@ public void setLimitTps(int limitTps) {
         this.limitTps = limitTps;
     }
 
-    public int getLimitTps() {
+    public Integer getLimitTps() {
         return limitTps;
     }
 
@@ -275,7 +275,7 @@ public void setLimitTraffic(int limitTraffic) {
         this.limitTraffic = limitTraffic;
     }
 
-    public int getLimitTraffic() {
+    public Integer getLimitTraffic() {
         return limitTraffic;
     }
 
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ProducerConfig.java b/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ProducerConfig.java
index e84b6f184..59382fe9f 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ProducerConfig.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-model/src/main/java/org/joyqueue/model/domain/ProducerConfig.java
@@ -28,7 +28,7 @@ public class ProducerConfig extends BaseNsrModel {
     /**
      * 是否就近发送
      **/
-    private boolean nearBy;
+    private Boolean nearBy;
 
     /**
      * 集群实例发送权重
@@ -38,18 +38,18 @@ public class ProducerConfig extends BaseNsrModel {
     /**
      * 是否归档
      */
-    private boolean archive;
+    private Boolean archive;
 
     /**
      * 单个发送者
      **/
-    private boolean single = false;
+    private Boolean single = false;
 
     private String blackList;
 
-    private int limitTps;
+    private Integer limitTps;
 
-    private int limitTraffic;
+    private Integer limitTraffic;
 
     private Integer timeout;
 
@@ -66,7 +66,7 @@ public void setProducerId(String producerId) {
         this.producerId = producerId;
     }
 
-    public boolean isNearBy() {
+    public Boolean isNearBy() {
         return nearBy;
     }
 
@@ -82,7 +82,7 @@ public void setWeight(String weight) {
         this.weight = weight;
     }
 
-    public boolean isSingle() {
+    public Boolean isSingle() {
         return single;
     }
 
@@ -90,7 +90,7 @@ public void setSingle(boolean single) {
         this.single = single;
     }
 
-    public boolean isArchive() {
+    public Boolean isArchive() {
         return archive;
     }
 
@@ -110,7 +110,7 @@ public void setLimitTps(int limitTps) {
         this.limitTps = limitTps;
     }
 
-    public int getLimitTps() {
+    public Integer getLimitTps() {
         return limitTps;
     }
 
@@ -118,7 +118,7 @@ public void setLimitTraffic(int limitTraffic) {
         this.limitTraffic = limitTraffic;
     }
 
-    public int getLimitTraffic() {
+    public Integer getLimitTraffic() {
         return limitTraffic;
     }
 
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-api/src/main/java/org/joyqueue/repository/BrokerGroupRelatedRepository.java b/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-api/src/main/java/org/joyqueue/repository/BrokerGroupRelatedRepository.java
index 3b3db3164..995348071 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-api/src/main/java/org/joyqueue/repository/BrokerGroupRelatedRepository.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-api/src/main/java/org/joyqueue/repository/BrokerGroupRelatedRepository.java
@@ -16,10 +16,13 @@
 package org.joyqueue.repository;
 
 
+import org.apache.ibatis.annotations.Param;
 import org.joyqueue.model.domain.BrokerGroupRelated;
 import org.joyqueue.model.query.QBrokerGroupRelated;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 /**
  * Created by lining on 16-11-28.
  */
@@ -27,4 +30,5 @@
 public interface BrokerGroupRelatedRepository extends PageRepository<BrokerGroupRelated,QBrokerGroupRelated> {
     int updateGroupByGroupId(BrokerGroupRelated brokerGroupRelated);
     int deleteByGroupId(long groupId);
+    List<BrokerGroupRelated> findByBrokerIds(@Param("brokerIds") List<Long> brokerIds);
 }
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-mybatis/src/main/resources/mapper/BrokerGroupRelated.xml b/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-mybatis/src/main/resources/mapper/BrokerGroupRelated.xml
index 7031e539d..b27fc8b2c 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-mybatis/src/main/resources/mapper/BrokerGroupRelated.xml
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-repository/joyqueue-data-repository-mybatis/src/main/resources/mapper/BrokerGroupRelated.xml
@@ -54,6 +54,14 @@
         WHERE b.id=#{id}
     </select>
 
+    <select id="findByBrokerIds" parameterType="long" resultType="BrokerGroupRelated">
+        <include refid="select"/>
+        WHERE b.id in
+        <foreach collection="brokerIds" item="id" index="i" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </select>
+
     <select id="findByIds" resultType="BrokerGroupRelated">
         <include refid="select"/>
         WHERE b.id IN
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 2e821e4e2..b29a671a6 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
@@ -496,8 +496,8 @@ public List<ApplicationToken> tokens(String app) {
     }
 
     @Override
-    public BrokerMonitorRecord brokerMonitor(Subscribe subscribe) {
-        return brokerMonitorService.find(subscribe, true);
+    public BrokerMonitorRecord brokerMonitor(Subscribe subscribe, boolean active) {
+        return brokerMonitorService.find(subscribe, active);
     }
 
     /**
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/OpenAPIService.java b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/OpenAPIService.java
index 20deba6e4..a26258f52 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/OpenAPIService.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/OpenAPIService.java
@@ -201,7 +201,7 @@ public interface OpenAPIService {
      **/
     List<ApplicationToken> tokens(String app);
 
-    BrokerMonitorRecord brokerMonitor(Subscribe subscribe);
+    BrokerMonitorRecord brokerMonitor(Subscribe subscribe, boolean active);
 
 
 }
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/BrokerGroupRelatedService.java b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/BrokerGroupRelatedService.java
index d21cae818..4f2acc2a1 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/BrokerGroupRelatedService.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/BrokerGroupRelatedService.java
@@ -16,8 +16,12 @@
 package org.joyqueue.service;
 
 import org.joyqueue.model.domain.BrokerGroupRelated;
+import org.joyqueue.model.domain.Identity;
 import org.joyqueue.model.query.QBrokerGroupRelated;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * 分组服务
  * Created by chenyanying3 on 2018-10-18.
@@ -25,4 +29,5 @@
 public interface BrokerGroupRelatedService extends PageService<BrokerGroupRelated, QBrokerGroupRelated> {
     int updateGroupByGroupId(BrokerGroupRelated brokerGroupRelated);
     int deleteByGroupId(long groupId);
+    Map<Long, Identity> findGroupByBrokerIds(List<Long> brokerIds);
 }
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerGroupRelatedServiceImpl.java b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerGroupRelatedServiceImpl.java
index 5dfbf7851..e7acd26a4 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerGroupRelatedServiceImpl.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerGroupRelatedServiceImpl.java
@@ -15,12 +15,19 @@
  */
 package org.joyqueue.service.impl;
 
+import org.apache.commons.collections.CollectionUtils;
 import org.joyqueue.model.domain.BrokerGroupRelated;
+import org.joyqueue.model.domain.Identity;
 import org.joyqueue.model.query.QBrokerGroupRelated;
 import org.joyqueue.repository.BrokerGroupRelatedRepository;
 import org.joyqueue.service.BrokerGroupRelatedService;
 import org.springframework.stereotype.Service;
 
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
 /**
  * 分组服务实现
  * Created by chenyanying3 on 2018-10-18
@@ -37,4 +44,16 @@ public int updateGroupByGroupId(BrokerGroupRelated brokerGroupRelated) {
     public int deleteByGroupId(long groupId) {
         return repository.deleteByGroupId(groupId);
     }
+
+    @Override
+    public Map<Long, Identity> findGroupByBrokerIds(List<Long> brokerIds) {
+        List<BrokerGroupRelated> brokerGroupRelateds = repository.findByBrokerIds(brokerIds);
+        if (CollectionUtils.isNotEmpty(brokerGroupRelateds)) {
+            return brokerGroupRelateds.stream()
+                    .filter(brokerGroupRelated -> brokerGroupRelated.getGroup() != null)
+                    .collect(Collectors.toMap(BrokerGroupRelated::getId,
+                            BrokerGroupRelated::getGroup));
+        }
+        return Collections.emptyMap();
+    }
 }
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerServiceImpl.java b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerServiceImpl.java
index b7314e2dd..77846fafb 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerServiceImpl.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/BrokerServiceImpl.java
@@ -236,10 +236,11 @@ private PageResult<Broker> searchMultiKeyword(QPageQuery<QBroker> qPageQuery) th
         PageResult<Broker> pageResult = brokerNameServerService.search(qPageQuery);
         if (pageResult != null && pageResult.getResult() != null && pageResult.getResult().size() > 0) {
             List<Broker> brokerList = pageResult.getResult();
+            Map<Long, Identity> brokerGroupMap = brokerGroupRelatedService.findGroupByBrokerIds(brokerList.stream().map(Broker::getId).collect(Collectors.toList()));
             for (Broker broker : brokerList) {
-                BrokerGroupRelated brokerRelated = brokerGroupRelatedService.findById(broker.getId());
-                if (brokerRelated != null && brokerRelated.getGroup() != null) {
-                    broker.setGroup(brokerRelated.getGroup());
+                Identity group = brokerGroupMap.get(broker.getId());
+                if (group != null) {
+                    broker.setGroup(group);
                     broker.setStatus(0);
                 }
             }
diff --git a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/ProducerServiceImpl.java b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/ProducerServiceImpl.java
index a28806cfd..168f41364 100644
--- a/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/ProducerServiceImpl.java
+++ b/joyqueue-console/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/service/impl/ProducerServiceImpl.java
@@ -185,6 +185,22 @@ protected Producer fillProducer(Producer producer) {
             app.setName(application.getName());
             producer.setOwner(application.getOwner());
         }
+        if (StringUtils.isNotBlank(producer.getConfig().getWeight())) {
+            String[] split = producer.getConfig().getWeight().split(",");
+            StringBuilder builder = new StringBuilder();
+            for (String item: split) {
+                String[] items = item.split(":");
+                if (Long.parseLong(items[1]) > 0) {
+                    builder.append(items[0]).append(":").append(items[1]).append(",");
+                }
+            }
+            if (builder.length() > 0) {
+                builder.deleteCharAt(builder.length() - 1);
+                producer.getConfig().setWeight(builder.toString());
+            } else {
+                producer.getConfig().setWeight(null);
+            }
+        }
         return producer;
     }
 
diff --git a/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ConsumerCommand.java b/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ConsumerCommand.java
index e82e7e14b..a20524452 100644
--- a/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ConsumerCommand.java
+++ b/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ConsumerCommand.java
@@ -24,6 +24,7 @@
 import com.jd.laf.web.vertx.response.Response;
 import com.jd.laf.web.vertx.response.Responses;
 import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.collections.MapUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.joyqueue.handler.Constants;
 import org.joyqueue.handler.annotation.PageQuery;
@@ -150,12 +151,85 @@ public Response delete(@QueryParam(Constants.ID) String id) throws Exception {
     public Response configAddOrUpdate(@Body ConsumerConfig config) throws Exception {
         if (config != null) {
             Consumer consumer = service.findById(config.getConsumerId());
-            consumer.setConfig(config);
+            mergeConsumerConfig(consumer, config);
             service.update(consumer);
         }
         return Responses.success();
     }
 
+    private void mergeConsumerConfig(Consumer consumer, ConsumerConfig config) {
+        if (consumer.getConfig() == null) {
+            consumer.setConfig(config);
+            return;
+        }
+        if (config.getAckTimeout() !=null) {
+            consumer.getConfig().setAckTimeout(config.getAckTimeout());
+        }
+        if (config.getBackOffMultiplier() != null) {
+            consumer.getConfig().setBackOffMultiplier(config.getBackOffMultiplier());
+        }
+        if (config.getBatchSize() != null) {
+            consumer.getConfig().setBatchSize(config.getBatchSize());
+        }
+        if (config.getConcurrent() != null) {
+            consumer.getConfig().setConcurrent(config.getConcurrent());
+        }
+        if (config.getDelay() != null) {
+            consumer.getConfig().setDelay(config.getDelay());
+        }
+        if (config.getRetryDelay() != null) {
+            consumer.getConfig().setRetryDelay(config.getRetryDelay());
+        }
+        if (config.getMaxRetrys() != null) {
+            consumer.getConfig().setMaxRetrys(config.getMaxRetrys());
+        }
+        if (config.getMaxRetryDelay() != null) {
+            consumer.getConfig().setMaxRetryDelay(config.getMaxRetryDelay());
+        }
+        if (config.getLimitTps() != null) {
+            consumer.getConfig().setLimitTps(config.getLimitTps());
+        }
+        if (config.getLimitTraffic() != null) {
+            consumer.getConfig().setLimitTraffic(config.getLimitTraffic());
+        }
+        if (StringUtils.isNotBlank(config.getRegion())) {
+            consumer.getConfig().setRegion(config.getRegion());
+        }
+        if (StringUtils.isNotBlank(config.getBlackList())) {
+            consumer.getConfig().setBlackList(config.getBlackList());
+        }
+        if (StringUtils.isNotBlank(config.getFilters())) {
+            consumer.getConfig().setFilters(config.getFilters());
+        }
+        if (config.isArchive() != null) {
+            consumer.getConfig().setArchive(config.isArchive());
+        }
+        if (config.isNearBy() != null) {
+            consumer.getConfig().setNearBy(config.isNearBy());
+        }
+        if (config.isPaused() != null) {
+            consumer.getConfig().setPaused(config.isPaused());
+        }
+        if (config.isRetry() != null) {
+            consumer.getConfig().setRetry(config.isRetry());
+        }
+        if (config.isUseExponentialBackOff() != null) {
+            consumer.getConfig().setUseExponentialBackOff(config.isUseExponentialBackOff());
+        }
+        if (MapUtils.isNotEmpty(config.getParams())) {
+            if (consumer.getConfig().getParams() == null) {
+                consumer.getConfig().setParams(config.getParams());
+            }else  {
+                consumer.getConfig().getParams().putAll(config.getParams());
+            }
+        }
+        if (config.getOffsetMode() != null) {
+            consumer.getConfig().setOffsetMode(config.getOffsetMode());
+        }
+        if (config.getExpireTime() != null) {
+            consumer.getConfig().setExpireTime(config.getExpireTime());
+        }
+    }
 
     /**
      * 同步producer
diff --git a/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerCommand.java b/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerCommand.java
index ff59ce260..0807cdec9 100644
--- a/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerCommand.java
+++ b/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerCommand.java
@@ -97,13 +97,7 @@ public Response pageQuery(@PageQuery QPageQuery<QProducer> qPageQuery) throws Ex
 
         if (appFlag) {
             if (CollectionUtils.isNotEmpty(producers) && session.getRole() != User.UserRole.ADMIN.value()) {
-                Iterator<Producer> iterator = producers.iterator();
-                while (iterator.hasNext()) {
-                    Producer producer = iterator.next();
-                    if (applicationUserService.findByUserApp(session.getCode(), producer.getApp().getCode()) == null) {
-                        iterator.remove();
-                    }
-                }
+                producers.removeIf(producer -> applicationUserService.findByUserApp(session.getCode(), producer.getApp().getCode()) == null);
             }
         }
 
diff --git a/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerConfigAddOrUpdateCommand.java b/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerConfigAddOrUpdateCommand.java
index 941fde38b..6dc988c5a 100644
--- a/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerConfigAddOrUpdateCommand.java
+++ b/joyqueue-console/joyqueue-web/joyqueue-web-handler/src/main/java/org/joyqueue/handler/routing/command/monitor/ProducerConfigAddOrUpdateCommand.java
@@ -16,6 +16,8 @@
 package org.joyqueue.handler.routing.command.monitor;
 
 
+import org.apache.commons.collections.MapUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.joyqueue.handler.annotation.Operator;
 import org.joyqueue.model.domain.Identity;
 import org.joyqueue.model.domain.Producer;
@@ -56,7 +58,7 @@ public String type() {
     public Response execute() throws Exception {
         Preconditions.checkArgument(null!=producerConfig,  "invalid argument");
         Producer producer = producerService.findById(producerConfig.getProducerId());
-        producer.setConfig(producerConfig);
+        mergeProducerConfig(producer, producerConfig);
         return Responses.success(producerService.update(producer));
     }
 
@@ -64,4 +66,49 @@ public Response execute() throws Exception {
     public void clean() {
         producerConfig = null;
     }
+
+    private void mergeProducerConfig(Producer producer, ProducerConfig config) {
+        if (producer.getConfig() == null) {
+            producer.setConfig(config);
+            return;
+        }
+        if (StringUtils.isNotBlank(config.getBlackList())) {
+            producer.getConfig().setBlackList(config.getBlackList());
+        }
+        if (StringUtils.isNotBlank(config.getRegion())) {
+            producer.getConfig().setRegion(config.getRegion());
+        }
+        if (StringUtils.isNotBlank(config.getWeight())) {
+            producer.getConfig().setWeight(config.getWeight());
+        }
+        if (config.isArchive() != null) {
+            producer.getConfig().setArchive(config.isArchive());
+        }
+        if (config.isNearBy() != null) {
+            producer.getConfig().setNearBy(config.isNearBy());
+        }
+        if (config.isSingle() != null) {
+            producer.getConfig().setSingle(config.isSingle());
+        }
+        if (config.getQosLevel() != null) {
+            producer.getConfig().setQosLevel(config.getQosLevel());
+        }
+        if (config.getLimitTps() != null) {
+            producer.getConfig().setLimitTps(config.getLimitTps());
+        }
+        if (config.getLimitTraffic() !=null) {
+            producer.getConfig().setLimitTraffic(config.getLimitTraffic());
+        }
+        if (MapUtils.isNotEmpty(config.getParams())) {
+            if (producer.getConfig().getParams() != null) {
+                producer.getConfig().getParams().putAll(config.getParams());
+            }else  {
+                producer.getConfig().setParams(config.getParams());
+            }
+        }
+        if (config.getTimeout() !=null) {
+            producer.getConfig().setTimeout(config.getTimeout());
+        }
+
+    }
 }