- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我无法使用RestHighLevelClient
连接到由Elastic Cloud托管的集群:
org.apache.http.ProtocolException: Not a valid protocol version: [0x1e][0x1f][0x20]*ÿÿÿÿ[0x26][0x27][0x28][0x2a][0x2b][0x2c][0x2d]No acceptable header received.
org.elasticsearch.client.Client
进行连接,但不能使用
org.elasticsearch.client.RestHighLevelClient
进行连接。
// this does not work
fun restHighLevelClient(): RestHighLevelClient {
val builder = RestClient.builder(HttpHost("https://xxxxxx.eu-central-1.aws.cloud.es.io:9343"))
builder.setHttpClientConfigCallback { callback ->
val provider = BasicCredentialsProvider()
provider.setCredentials(AuthScope.ANY, UsernamePasswordCredentials("my-user", "my-password"))
callback.setDefaultCredentialsProvider(provider)
}
return RestHighLevelClient(builder)
}
// this works
fun client(): Client {
val settings = Settings.builder()
.put("client.transport.nodes_sampler_interval", "5s")
.put("transport.tcp.compress", true)
.put("cluster.name", "xxxxxx")
.put("xpack.security.transport.ssl.enabled", true)
.put("request.headers.X-Found-Cluster", "\${cluster.name}")
.put("xpack.security.user", "my-user:my-password")
.build()
val client = PreBuiltXPackTransportClient(settings)
for (address in InetAddress.getAllByName("xxxxxx.eu-central-1.aws.cloud.es.io")) {
client.addTransportAddress(TransportAddress(address, 9343))
}
return client
}
2019-04-04 10:24:46.977 WARN 13025 --- [on(3)-127.0.0.1] s.b.a.e.ElasticsearchRestHealthIndicator : Elasticsearch health check failed
java.lang.RuntimeException: error while performing request
at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:959) ~[elasticsearch-rest-client-6.5.4.jar:6.5.4]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:229) ~[elasticsearch-rest-client-6.5.4.jar:6.5.4]
at org.springframework.boot.actuate.elasticsearch.ElasticsearchRestHealthIndicator.doHealthCheck(ElasticsearchRestHealthIndicator.java:61) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at org.springframework.boot.actuate.health.AbstractHealthIndicator.health(AbstractHealthIndicator.java:84) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at org.springframework.boot.actuate.health.CompositeHealthIndicator.health(CompositeHealthIndicator.java:98) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at org.springframework.boot.actuate.health.HealthEndpoint.health(HealthEndpoint.java:50) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na]
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:na]
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na]
at java.base/java.lang.reflect.Method.invoke(Method.java:566) ~[na:na]
at org.springframework.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:246) ~[spring-core-5.1.5.RELEASE.jar:5.1.5.RELEASE]
at org.springframework.boot.actuate.endpoint.invoke.reflect.ReflectiveOperationInvoker.invoke(ReflectiveOperationInvoker.java:76) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at org.springframework.boot.actuate.endpoint.annotation.AbstractDiscoveredOperation.invoke(AbstractDiscoveredOperation.java:61) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at org.springframework.boot.actuate.endpoint.jmx.EndpointMBean.invoke(EndpointMBean.java:126) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at org.springframework.boot.actuate.endpoint.jmx.EndpointMBean.invoke(EndpointMBean.java:99) ~[spring-boot-actuator-2.1.3.RELEASE.jar:2.1.3.RELEASE]
at java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanServerInterceptor.java:809) ~[na:na]
at java.management/com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:801) ~[na:na]
at java.management.rmi/javax.management.remote.rmi.RMIConnectionImpl.doOperation(RMIConnectionImpl.java:1466) ~[na:na]
at java.management.rmi/javax.management.remote.rmi.RMIConnectionImpl$PrivilegedOperation.run(RMIConnectionImpl.java:1307) ~[na:na]
at java.management.rmi/javax.management.remote.rmi.RMIConnectionImpl.doPrivilegedOperation(RMIConnectionImpl.java:1399) ~[na:na]
at java.management.rmi/javax.management.remote.rmi.RMIConnectionImpl.invoke(RMIConnectionImpl.java:827) ~[na:na]
at java.base/jdk.internal.reflect.GeneratedMethodAccessor125.invoke(Unknown Source) ~[na:na]
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na]
at java.base/java.lang.reflect.Method.invoke(Method.java:566) ~[na:na]
at java.rmi/sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:359) ~[na:na]
at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:200) ~[na:na]
at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:197) ~[na:na]
at java.base/java.security.AccessController.doPrivileged(Native Method) ~[na:na]
at java.rmi/sun.rmi.transport.Transport.serviceCall(Transport.java:196) ~[na:na]
at java.rmi/sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:562) ~[na:na]
at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:796) ~[na:na]
at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:677) ~[na:na]
at java.base/java.security.AccessController.doPrivileged(Native Method) ~[na:na]
at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:676) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[na:na]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
Caused by: org.apache.http.ProtocolException: Not a valid protocol version: [0x1e][0x1f][0x20]*ÿÿÿÿ[0x26][0x27][0x28][0x2a][0x2b][0x2c][0x2d]No acceptable header received.
at org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81) ~[httpasyncclient-4.1.4.jar:4.1.4]
at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39) ~[httpasyncclient-4.1.4.jar:4.1.4]
at org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:121) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591) ~[httpcore-nio-4.4.11.jar:4.4.11]
... 1 common frames omitted
Caused by: org.apache.http.ParseException: Not a valid protocol version: *ÿÿÿÿ No acceptable header received.
at org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148) ~[httpcore-4.4.11.jar:4.4.11]
at org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366) ~[httpcore-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156) ~[httpcore-nio-4.4.11.jar:4.4.11]
at org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207) ~[httpcore-nio-4.4.11.jar:4.4.11]
... 11 common frames omitted
ext['elasticsearch.version'] = 6.5.4
dependencyManagement {
imports {
mavenBom "org.springframework.boot:spring-boot-dependencies:2.1.3.RELEASE"
}
}
dependencies {
compile "com.unboundid:unboundid-ldapsdk:4.0.9"
compile "org.elasticsearch.client:elasticsearch-rest-client:6.5.4"
compile "org.elasticsearch.client:elasticsearch-rest-high-level-client:6.5.4"
compile "org.elasticsearch.client:transport:6.5.4"
compile "org.elasticsearch.client:x-pack-transport:6.5.4"
compile "org.elasticsearch.plugin:transport-netty4-client:6.5.4"
compile "org.elasticsearch:elasticsearch:6.5.4"
compile "org.springframework.boot:spring-boot"
compile "org.springframework.boot:spring-boot-autoconfigure"
compile "org.springframework.data:spring-data-elasticsearch:3.2.0.M2"
}
+--- com.unboundid:unboundid-ldapsdk:4.0.9
+--- org.elasticsearch.client:elasticsearch-rest-client:6.5.4
| +--- org.apache.httpcomponents:httpclient:4.5.2 -> 4.5.7 (*)
| +--- org.apache.httpcomponents:httpcore:4.4.5 -> 4.4.11
| +--- org.apache.httpcomponents:httpasyncclient:4.1.2 -> 4.1.4
| +--- org.apache.httpcomponents:httpcore-nio:4.4.5 -> 4.4.11
| \--- commons-codec:commons-codec:1.10 -> 1.11
+--- org.elasticsearch.client:elasticsearch-rest-high-level-client:6.5.4
| +--- org.elasticsearch:elasticsearch:6.5.4
| | +--- org.elasticsearch:elasticsearch-core:6.5.4
| | +--- org.elasticsearch:elasticsearch-secure-sm:6.5.4
| | +--- org.elasticsearch:elasticsearch-x-content:6.5.4
| | | +--- org.elasticsearch:elasticsearch-core:6.5.4
| | | +--- org.yaml:snakeyaml:1.17 -> 1.23
| | | +--- com.fasterxml.jackson.core:jackson-core:2.8.11 -> 2.9.8
| | | +--- com.fasterxml.jackson.dataformat:jackson-dataformat-smile:2.8.11 -> 2.9.8
| | | +--- com.fasterxml.jackson.dataformat:jackson-dataformat-yaml:2.8.11 -> 2.9.8
| | | \--- com.fasterxml.jackson.dataformat:jackson-dataformat-cbor:2.8.11 -> 2.9.8 (*)
| | +--- org.apache.lucene:lucene-core:7.5.0
| | +--- org.apache.lucene:lucene-analyzers-common:7.5.0
| | +--- org.apache.lucene:lucene-backward-codecs:7.5.0
| | +--- org.apache.lucene:lucene-grouping:7.5.0
| | +--- org.apache.lucene:lucene-highlighter:7.5.0
| | +--- org.apache.lucene:lucene-join:7.5.0
| | +--- org.apache.lucene:lucene-memory:7.5.0
| | +--- org.apache.lucene:lucene-misc:7.5.0
| | +--- org.apache.lucene:lucene-queries:7.5.0
| | +--- org.apache.lucene:lucene-queryparser:7.5.0
| | +--- org.apache.lucene:lucene-sandbox:7.5.0
| | +--- org.apache.lucene:lucene-spatial:7.5.0
| | +--- org.apache.lucene:lucene-spatial-extras:7.5.0
| | +--- org.apache.lucene:lucene-spatial3d:7.5.0
| | +--- org.apache.lucene:lucene-suggest:7.5.0
| | +--- org.elasticsearch:elasticsearch-cli:6.5.4
| | | +--- net.sf.jopt-simple:jopt-simple:5.0.2
| | | \--- org.elasticsearch:elasticsearch-core:6.5.4
| | +--- com.carrotsearch:hppc:0.7.1
| | +--- joda-time:joda-time:2.10.1
| | +--- com.tdunning:t-digest:3.2
| | +--- org.hdrhistogram:HdrHistogram:2.1.9
| | +--- org.apache.logging.log4j:log4j-api:2.11.1 -> 2.11.2
| | \--- org.elasticsearch:jna:4.5.1
| +--- org.elasticsearch.client:elasticsearch-rest-client:6.5.4 (*)
| +--- org.elasticsearch.plugin:parent-join-client:6.5.4
| +--- org.elasticsearch.plugin:aggs-matrix-stats-client:6.5.4
| +--- org.elasticsearch.plugin:rank-eval-client:6.5.4
| \--- org.elasticsearch.plugin:lang-mustache-client:6.5.4
| \--- com.github.spullara.mustache.java:compiler:0.9.3
+--- org.elasticsearch.client:transport:6.5.4
| +--- org.elasticsearch:elasticsearch:6.5.4 (*)
| +--- org.elasticsearch.plugin:transport-netty4-client:6.5.4
| | +--- io.netty:netty-buffer:4.1.30.Final -> 4.1.33.Final
| | +--- io.netty:netty-codec:4.1.30.Final -> 4.1.33.Final
| | +--- io.netty:netty-codec-http:4.1.30.Final -> 4.1.33.Final
| | +--- io.netty:netty-common:4.1.30.Final -> 4.1.33.Final
| | +--- io.netty:netty-handler:4.1.30.Final -> 4.1.33.Final
| | +--- io.netty:netty-resolver:4.1.30.Final -> 4.1.33.Final
| | \--- io.netty:netty-transport:4.1.30.Final -> 4.1.33.Final
| +--- org.elasticsearch.plugin:reindex-client:6.5.4
| | \--- org.elasticsearch.client:elasticsearch-rest-client:6.5.4 (*)
| +--- org.elasticsearch.plugin:lang-mustache-client:6.5.4 (*)
| +--- org.elasticsearch.plugin:percolator-client:6.5.4
| +--- org.elasticsearch.plugin:parent-join-client:6.5.4
| \--- org.elasticsearch.plugin:rank-eval-client:6.5.4
+--- org.elasticsearch.client:x-pack-transport:6.5.4
| +--- org.elasticsearch.plugin:x-pack-core:6.5.4
| \--- org.elasticsearch.client:transport:6.5.4 (*)
+--- org.elasticsearch.plugin:transport-netty4-client:6.5.4 (*)
+--- org.elasticsearch:elasticsearch:6.5.4 (*)
+--- org.springframework.boot:spring-boot:2.1.3.RELEASE (*)
+--- org.springframework.boot:spring-boot-autoconfigure:2.1.3.RELEASE (*)
\--- org.springframework.data:spring-data-elasticsearch:3.2.0.M1 -> 3.2.0.M2
+--- org.springframework:spring-context:5.1.5.RELEASE (*)
+--- org.springframework:spring-tx:5.1.5.RELEASE (*)
+--- org.springframework.data:spring-data-commons:2.2.0.M2 -> 2.1.5.RELEASE (*)
+--- joda-time:joda-time:2.10.1
+--- org.elasticsearch.client:transport:6.6.1 -> 6.5.4 (*)
+--- org.elasticsearch.plugin:transport-netty4-client:6.6.1 -> 6.5.4 (*)
+--- org.elasticsearch.client:elasticsearch-rest-high-level-client:6.6.1 -> 6.5.4 (*)
+--- com.fasterxml.jackson.core:jackson-core:2.9.8
+--- com.fasterxml.jackson.core:jackson-databind:2.9.8 (*)
\--- org.slf4j:slf4j-api:1.7.25
最佳答案
不好,我使用的是错误的Elasticsearch Rest端口:-(
以下是 flex 云的端口:
关于elasticsearch - Elasticsearch-RestHighLevelClient与弹性云的连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55516320/
我正在尝试从需要访问外部请求代理的网络中访问Cloud Elasticsearch安装。这是我用来传递Elasticsearch凭证和我们的代理设置的代码片段: CredentialsProvider
如果elasticsearch在单一模式下运行,我可以使用以下代码轻松建立RestHighLevel连接: RestHighLevelClient client = new RestHighLevel
我想用RestHighLevelClient在不同集群上使用 Cross Cluster mechanizem 不支持的命令(例如关闭和打开索引)。 我的问题是我是否使用了多个 RestHighLev
我需要模拟 RestHighLevelClient 来测试我的代码。基本上,当我调用 RestHighLevelClient 的“搜索”方法时,我得到 UnfinishedStubbingExcept
我正在对包含空格的字段执行搜索,我希望不对其进行分析,即不将其拆分为克并被视为单个实体。我如何在 Java 中执行此操作? 我正在使用 RESTHighLevelClient 版本 7.4。 最佳答案
我正在尝试通过此依赖项使用 RestHighLevelClient org.elasticsearch.client elasticsearch-rest-h
我正在尝试在 Scala 程序中插入 ElasticSearch(ES)。 在 build.sbt 我添加了 libraryDependencies += "org.elasticsearch.cli
我正在使用vpc端点进行 flex 搜索,以使用RestHighLevelClient索引我的文档。 我正在使用Java高级休息客户端v6.2.2连接Elasticsearch 6.0版 我无需任何身
我想知道这里是否有人使用 RestHighLevelClient 连接到 AWS ElasticSearch。不确定 AWS ElasticSearch 是否支持此功能。目前,每次尝试连接时,我都会收
我正在使用 Elasticsearch RestHighLevelClient 并尝试实现下面的 sql: select format(date,'yyyy-MM-dd'), count(*) fro
我使用 MultiSearchRequest 按字段的一部分在 Elasticsearch 中进行搜索: @Override public Collection> findContractsByInd
我在 Elasticsearch 中为 RestHighLevelClient 使用以下代码。 val credentialsProvider = new BasicCredentialsProvid
当索引 100k 文档时,以下行出现 listener 超时异常 IndexResponse response = SearchEngineClient.getInstance2().index(re
我试过下面的代码它工作正常,但它使用 运输客户端 删除所有文档。 DeleteByQueryRequestBuilder deleteByQueryRequestBuilder = DeleteByQ
我们的应用程序在 elasticsearch 服务器中索引(存储)文档时遇到超时异常。它不会经常发生,但大约每天一次。这是详细信息。 pom.xml org.elasticsearch.cl
Elastic 正在更新他们的文档以使用带有 Java 的 RestHighLevelClient。它还具有映射 API: https://www.elastic.co/guide/en/elasti
我在 SpringBoot 应用程序中创建 HighEndRestClient bean 时遇到错误。我已经完成了一个测试“应用程序”,我检查了我可以实例化我想要的对象,然后进行我想要的调用,现在我正
如何在下面使用bool创建RestHighLevelClient查询? 我的尝试未返回任何内容: BoolQueryBuilder query = boolQuery()
在我的 Elasticsearch 索引中,我保存了大约 30000 个实体。我想使用 RestHighLevelClient 获取它们的所有 id。我读过最好的方法是使用滚动 api。但是,当我这样
在我的 Scala 项目中,我试图用新的 RestHighLevelClient 更改旧的 transportClient 以连接到 Elasticsearch (6.1)。 但我在尝试创建 Bulk
我是一名优秀的程序员,十分优秀!