Skip to content

Commit

Permalink
将ProducerConfig,ConsumerConfig基础类型字段改为装箱类型
Browse files Browse the repository at this point in the history
  • Loading branch information
iamazy committed Oct 13, 2020
1 parent 5636223 commit e5dd2fb
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -206,13 +206,13 @@ private void mergeConsumerConfig(Consumer consumer, ConsumerConfig config) {
if (config.getLimitTraffic() != null) {
consumer.getConfig().setLimitTraffic(config.getLimitTraffic());
}
if (StringUtils.isNotBlank(config.getRegion())) {
if (config.getRegion() != null) {
consumer.getConfig().setRegion(config.getRegion());
}
if (StringUtils.isNotBlank(config.getBlackList())) {
if (config.getBlackList() != null) {
consumer.getConfig().setBlackList(config.getBlackList());
}
if (StringUtils.isNotBlank(config.getFilters())) {
if (config.getFilters() != null) {
consumer.getConfig().setFilters(config.getFilters());
}
if (config.isArchive() != null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,10 +72,10 @@ private void mergeProducerConfig(Producer producer, ProducerConfig config) {
producer.setConfig(config);
return;
}
if (StringUtils.isNotBlank(config.getBlackList())) {
if (config.getBlackList() != null) {
producer.getConfig().setBlackList(config.getBlackList());
}
if (StringUtils.isNotBlank(config.getRegion())) {
if (config.getRegion() != null) {
producer.getConfig().setRegion(config.getRegion());
}
if (StringUtils.isNotBlank(config.getWeight())) {
Expand Down

0 comments on commit e5dd2fb

Please sign in to comment.