diff --git a/app.yml b/app.yml
index 033c61a7c47f8978c7a0c5197c29bf760ba4a5dd..a02ec8c0eb1b322f674bc02bd8b763f45b18d32f 100644
--- a/app.yml
+++ b/app.yml
@@ -50,8 +50,8 @@ redis_addrs: 127.0.0.1:6379 #redis地址，多个用逗号分隔
 #elasticsearch连接配置
 #es_addrs: 127.0.0.1:9200 #连接地址，多个用逗号分隔
 #es_version: 7 # Elasticsearch版本，支持6和7、默认为7
-#es_password:  # 用户名
-#es_version:  # 密码
+#es_user:       # 用户名
+#es_password:   # 密码
 
 #rocketmq连接配置
 #rocketmq_name_servers: 127.0.0.1:9876 #rocketmq命名服务地址，多个用逗号分隔
diff --git a/service/endpoint/elastic6.go b/service/endpoint/elastic6.go
index 5b0d75b8e49f7eddf8739fa0c8877dc95c8a0cb6..e3bd07b3acffca8a45b37dfcaf026522dba70271 100644
--- a/service/endpoint/elastic6.go
+++ b/service/endpoint/elastic6.go
@@ -57,8 +57,9 @@ func (s *Elastic6Endpoint) Connect() error {
 	options = append(options, elastic.SetErrorLog(logagent.NewElsLoggerAgent()))
 	options = append(options, elastic.SetURL(s.hosts...))
 	if global.Cfg().ElsUser != "" && global.Cfg().ElsPassword != "" {
-		options = append(options, elastic.SetBasicAuth(global.Cfg().ElsUser, global.Cfg().Password))
+		options = append(options, elastic.SetBasicAuth(global.Cfg().ElsUser, global.Cfg().ElsPassword))
 	}
+	options = append(options, elastic.SetSniff(false))
 
 	client, err := elastic.NewClient(options...)
 	if err != nil {
diff --git a/service/endpoint/elastic7.go b/service/endpoint/elastic7.go
index 3164b6d9f37c2ae25ab11a95fa206b71b6bfb44c..6807f2cf79d221eefbe19bbf3ea8ddd379b9acb7 100644
--- a/service/endpoint/elastic7.go
+++ b/service/endpoint/elastic7.go
@@ -57,8 +57,9 @@ func (s *Elastic7Endpoint) Connect() error {
 	options = append(options, elastic.SetErrorLog(logagent.NewElsLoggerAgent()))
 	options = append(options, elastic.SetURL(s.hosts...))
 	if global.Cfg().ElsUser != "" && global.Cfg().ElsPassword != "" {
-		options = append(options, elastic.SetBasicAuth(global.Cfg().ElsUser, global.Cfg().Password))
+		options = append(options, elastic.SetBasicAuth(global.Cfg().ElsUser, global.Cfg().ElsPassword))
 	}
+	options = append(options, elastic.SetSniff(false))
 
 	client, err := elastic.NewClient(options...)
 	if err != nil {