优化元数据相关 (#328)

* 优化元数据
* nameeserver-sql修改默认配置，无需配置默认使用h2
* 删除ignite和composition模块
* 删除ignite相关配置
* 自动选择多协调者
* 去掉无用变量
* 调整补偿
* 修复空列表的sql错误
* broker添加模糊搜索和精确搜索选项
* 调整默认schema

joyqueue-common/joyqueue-model/src/main/java/org/joyqueue/domain/TopicConfig.java

@@ -16,6 +16,7 @@
 package org.joyqueue.domain;
 
 import com.google.common.collect.Maps;
+import com.google.common.collect.Sets;
 import org.apache.commons.collections.MapUtils;
 
 import java.io.Serializable;
@@ -41,6 +42,8 @@ public class TopicConfig extends Topic implements Serializable {
 
     private Map<Integer,PartitionGroup> partitionGroups;
 
+    private Set<Integer> replicas;
+
     /**
      * 主题配置转换
      *
@@ -89,12 +92,7 @@ public Map<Integer,PartitionGroup> getPartitionGroups() {
     }
 
     public boolean isReplica(int brokerId) {
-        for (Map.Entry<Integer, PartitionGroup> entry : partitionGroups.entrySet()) {
-            if (entry.getValue().getReplicas().contains(brokerId)) {
-                return true;
-            }
-        }
-        return false;
+        return replicas.contains(brokerId);
     }
 
     public List<PartitionGroup> fetchTopicPartitionGroupsByBrokerId(int brokerId) {
@@ -110,6 +108,15 @@ public List<PartitionGroup> fetchTopicPartitionGroupsByBrokerId(int brokerId) {
     public void setPartitionGroups(Map<Integer,PartitionGroup> partitionGroups) {
         this.partitionGroups = partitionGroups;
         this.partitionGroupMap = buildPartitionGroupMap(partitionGroups);
+        this.replicas = buildReplica(partitionGroups);
+    }
+
+    private Set<Integer> buildReplica(Map<Integer, PartitionGroup> partitionGroups) {
+        Set<Integer> result = Sets.newHashSet();
+        for (Map.Entry<Integer, PartitionGroup> partitionGroupEntry : partitionGroups.entrySet()) {
+            result.addAll(partitionGroupEntry.getValue().getReplicas());
+        }
+        return result;
     }
 
     private Map<Short, PartitionGroup> buildPartitionGroupMap(Map<Integer,PartitionGroup> partitionGroups) {