为什么knowstream会报错误Caused by: java.util.concurrent.ExecutionException: java.net.ConnectException: 拒绝连接，这是为什么？knowstream部署在其中一个kafka节点，9092，2181，与9999端口都是通的

[lianglinhuan]

• 我已经在 issues 搜索过相关问题了,并没有重复的。

在这里提出你的问题

2024-07-09 15:22:00.170 ERROR 3183380 --- [ool-7-thread-18] errorLogger : method=doQuery||indexName=[ks_kafka_topic_metric_2024-07-08,ks_kafka_topic_metric_2024-07-09]||queryDsl={"query":{"bool":{"must":[{"term":{"clusterPhyId":{"value":1}}},{"term":{"topic":{"value":"order_bike"}}},{"term":{"brokerAgg":{"value":"1"}}},{"range":{"timestamp":{"gte":1720509120167,"lte":1720509720167}}}],"must_not":[{"term":{"metrics.PartitionURP":{"value":0.0}}}]}}}||errMsg=query error.

org.elasticsearch.common.util.concurrent.UncategorizedExecutionException: Failed execution
at org.elasticsearch.action.support.AdapterActionFuture.rethrowExecutionException(AdapterActionFuture.java:91)
at org.elasticsearch.action.support.AdapterActionFuture.actionGet(AdapterActionFuture.java:74)
at com.xiaojukeji.know.streaming.km.persistence.es.ESOpClient.doQuery(ESOpClient.java:445)
at com.xiaojukeji.know.streaming.km.persistence.es.ESOpClient.performRequestWithRouting(ESOpClient.java:234)
at com.xiaojukeji.know.streaming.km.persistence.es.dao.TopicMetricESDAO.countMetricValue(TopicMetricESDAO.java:132)
at com.xiaojukeji.know.streaming.km.core.service.topic.impl.TopicMetricServiceImpl.countMetricValueOccurrencesFromES(TopicMetricServiceImpl.java:303)
at com.xiaojukeji.know.streaming.km.core.service.health.checker.topic.HealthCheckTopicService.checkTopicUnderReplicatedPartition(HealthCheckTopicService.java:79)
at com.xiaojukeji.know.streaming.km.core.service.health.checker.AbstractHealthCheckService.checkAndGetResult(AbstractHealthCheckService.java:48)
at com.xiaojukeji.know.streaming.km.task.health.HealthCheckTask.checkAndGetResult(HealthCheckTask.java:120)
at com.xiaojukeji.know.streaming.km.task.health.HealthCheckTask.calAndUpdateHealthCheckResult(HealthCheckTask.java:66)
at com.xiaojukeji.know.streaming.km.task.health.HealthCheckTask.processClusterTask(HealthCheckTask.java:45)
at com.xiaojukeji.know.streaming.km.task.metrics.AbstractAsyncMetricsDispatchTask.lambda$asyncProcessSubTask$0(AbstractAsyncMetricsDispatchTask.java:33)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.util.concurrent.ExecutionException: java.net.ConnectException: 拒绝连接
at org.elasticsearch.common.util.concurrent.BaseFuture$Sync.getValue(BaseFuture.java:290)
at org.elasticsearch.common.util.concurrent.BaseFuture$Sync.get(BaseFuture.java:263)
at org.elasticsearch.common.util.concurrent.BaseFuture.get(BaseFuture.java:94)
at org.elasticsearch.action.support.AdapterActionFuture.actionGet(AdapterActionFuture.java:68)
... 15 common frames omitted
Caused by: java.net.ConnectException: 拒绝连接
at java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:779)
at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)
at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)
at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)
at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)
at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)
... 1 common frames omitted