Skip to content

Commit 5641cd6

Browse files
author
wjj
committed
增加集群名配置
1 parent 479f033 commit 5641cd6

File tree

2 files changed

+10
-1
lines changed

2 files changed

+10
-1
lines changed

README.md

+2
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,8 @@ java.url=jdbc:elasticsearch://192.168.70.128:9300
8181
http.url=http://192.168.70.128:9200
8282
#max connection number
8383
maxActive=20
84+
#cluster name,ignored if you not setting
85+
cluster.name=elasticsearch
8486
```
8587

8688

src/main/java/com/wjj/jdbc/util/ESUtil.java

+8-1
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,14 @@ private static ESClient createClient(String jdbcUrl){
4242
jdbcUrl = PropertiesUtil.getValue("java.url");
4343
}
4444
TransportClient transportClient = null;
45-
Settings settings = Settings.builder().put("client.transport.ignore_cluster_name", true).build();
45+
String clusterName = PropertiesUtil.getValue("cluster.name");
46+
Settings.Builder builder = Settings.builder();
47+
if(StringUtils.isBlank(clusterName)){
48+
builder.put("client.transport.ignore_cluster_name", true);
49+
}else{
50+
builder.put("cluster.name", clusterName);
51+
}
52+
Settings settings = builder.build();
4653
try {
4754
transportClient = TransportClient.builder().settings(settings).build();
4855

0 commit comments

Comments
 (0)