diff --git a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java index bd397e75..b5fdabdc 100644 --- a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java +++ b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java @@ -4,6 +4,10 @@ import lombok.*; import org.elasticsearch.common.settings.Settings; import org.springframework.boot.context.properties.ConfigurationProperties; +import java.util.HashMap; +import java.util.Map; +import java.util.function.Function; + @Getter @Setter @Builder @@ -16,11 +20,14 @@ public class ElasticSearchIndexProperties { private int numberOfReplicas = 0; + private Map options = new HashMap<>(); + public Settings toSettings() { return Settings.builder() .put("number_of_shards", Math.max(1, numberOfShards)) .put("number_of_replicas", numberOfReplicas) + .putProperties(options, Function.identity()) .build(); } }