为什么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