zk版本不兼容如何处理

niejian commented 8 months ago

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

在这里提出你的问题

kafka版本 2.4.1 代码：master分支 kafka连接的zk版本：3.4.6 添加集群提示链接失败报错提示：


kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
    at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:271)
    at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:125)
    at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1948)
    at kafka.zk.KafkaZkClient.apply(KafkaZkClient.scala)
    at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.createZKClient(KafkaAdminZKClient.java:137)
    at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.createZKClient(KafkaAdminZKClient.java:121)
    at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.getClient(KafkaAdminZKClient.java:45)
    at com.xiaojukeji.know.streaming.km.core.flusher.zk.AbstractZKWatcher.flush(AbstractZKWatcher.java:49)
    at com.xiaojukeji.know.streaming.km.core.flusher.ZKWatcherManager.lambda$scheduledTriggerFlush$0(ZKWatcherManager.java:51)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
    at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
    at java.base/java.lang.Thread.run(Thread.java:833)

现在master分支使用的zk客户端是3.6.3，与实际项目中的zk server 3.4.6版本相差挺大，该如何处理

ZQKC commented 8 months ago

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

在这里提出你的问题

kafka版本 2.4.1 代码：master分支 kafka连接的zk版本：3.4.6 添加集群提示链接失败报错提示：


kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
  at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:271)
  at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:125)
  at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1948)
  at kafka.zk.KafkaZkClient.apply(KafkaZkClient.scala)
  at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.createZKClient(KafkaAdminZKClient.java:137)
  at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.createZKClient(KafkaAdminZKClient.java:121)
  at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.getClient(KafkaAdminZKClient.java:45)
  at com.xiaojukeji.know.streaming.km.core.flusher.zk.AbstractZKWatcher.flush(AbstractZKWatcher.java:49)
  at com.xiaojukeji.know.streaming.km.core.flusher.ZKWatcherManager.lambda$scheduledTriggerFlush$0(ZKWatcherManager.java:51)
  at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
  at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
  at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
  at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
  at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
  at java.base/java.lang.Thread.run(Thread.java:833)

现在master分支使用的zk客户端是3.6.3，与实际项目中的zk server 3.4.6版本相差挺大，该如何处理

1、版本兼容问题，可以试着使用3.6.3的客户端与3.4.6的客户端，分别KS所在的机器，连接一下ZK服务，看是否能成功连接上。

2、唯有版本不一样这个单一变量的情况下，如果3.4.6可以，而3.6.3不行，那么是版本兼容的问题。

3、现在是提示超时，不好确定就一定是版本兼容的问题。

niejian commented 8 months ago

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

在这里提出你的问题

kafka版本 2.4.1 代码：master分支 kafka连接的zk版本：3.4.6 添加集群提示链接失败报错提示：
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
    at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:271)
    at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:125)
    at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1948)
    at kafka.zk.KafkaZkClient.apply(KafkaZkClient.scala)
    at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.createZKClient(KafkaAdminZKClient.java:137)
    at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.createZKClient(KafkaAdminZKClient.java:121)
    at com.xiaojukeji.know.streaming.km.persistence.kafka.KafkaAdminZKClient.getClient(KafkaAdminZKClient.java:45)
    at com.xiaojukeji.know.streaming.km.core.flusher.zk.AbstractZKWatcher.flush(AbstractZKWatcher.java:49)
    at com.xiaojukeji.know.streaming.km.core.flusher.ZKWatcherManager.lambda$scheduledTriggerFlush$0(ZKWatcherManager.java:51)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
    at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
    at java.base/java.lang.Thread.run(Thread.java:833)
现在master分支使用的zk客户端是3.6.3，与实际项目中的zk server 3.4.6版本相差挺大，该如何处理
1、版本兼容问题，可以试着使用3.6.3的客户端与3.4.6的客户端，分别KS所在的机器，连接一下ZK服务，看是否能成功连接上。

2、唯有版本不一样这个单一变量的情况下，如果3.4.6可以，而3.6.3不行，那么是版本兼容的问题。

3、现在是提示超时，不好确定就一定是版本兼容的问题。

使用kafka（2.4.1）内置zk（3.5.7）无以上报错, 但是提示连接超时，调试代码发现会分别连接三个zk节点的1099端口，不知道这个端口是用来干嘛的

ZQKC commented 8 months ago

使用kafka（2.4.1）内置zk（3.5.7）无以上报错, 但是提示连接超时，调试代码发现会分别连接三个zk节点的1099端口，不知道这个端口是用来干嘛的

@niejian 是把ks使用的zk版本修改为3.5.7么？连接1099，具体对应的日志是？辛苦补全：什么环境，修改了什么，期望的结果，对应的结果，相关日志是？

niejian commented 7 months ago

使用kafka（2.4.1）内置zk（3.5.7）无以上报错, 但是提示连接超时，调试代码发现会分别连接三个zk节点的1099端口，不知道这个端口是用来干嘛的

@niejian 是把ks使用的zk版本修改为3.5.7么？连接1099，具体对应的日志是？辛苦补全：什么环境，修改了什么，期望的结果，对应的结果，相关日志是？

@ZQKC

我在本地环境下启动ks和kafka集群，连接zk没问题，但是如果本地启动的ks链接虚拟机下部署的kafka集群，一直提示连接zk超时（虚拟机防火墙已经关闭并且能telnet通），请问请问一下，ks的部署是不是要跟zk在一台机器上？我用如下代码测试

KafkaZkClient kafkaZkClient = KafkaZkClient.apply(
                    // "192.168.240.42:3181,192.168.240.43:3181,192.168.240.44:3181",
                    // "192.168.240.53:2181",
                    "192.168.240.15:2181",
                    // "localhost:2181",
                    false,
                    // zkConfig.getOpenSecure(),
                    15000,
                    // zkConfig.getSessionTimeoutUnitMs(),
                    // zkConfig.getRequestTimeoutUnitMs(),
                    15000,
                    5,
                    Time.SYSTEM,
                    "KS-ZK-ClusterPhyId-1",
                    "KS-ZK-SessionExpireListener-clusterPhyId-1",
                    Option.apply("KS-ZK-ClusterPhyId-1"),
                    Option.apply(getZKConfig(1L, new Properties()))
            );

报错日志

"C:\Program Files\Java\jdk1.8.0_161\bin\java.exe" -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:56832,suspend=y,server=n -javaagent:C:\Users\admin\AppData\Local\JetBrains\IdeaIC2023.2\captureAgent\debugger-agent.jar -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_161\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\rt.jar;D:\java-project\knowstream-3.0.0\km-rest\target\classes;D:\java-project\knowstream-3.0.0\km-extends\km-account\target\classes;D:\java-project\knowstream-3.0.0\km-common\target\classes;D:\myreposity\org\apache\zookeeper\zookeeper\3.5.7\zookeeper-3.5.7.jar;D:\myreposity\org\apache\zookeeper\zookeeper-jute\3.5.7\zookeeper-jute-3.5.7.jar;D:\myreposity\org\apache\yetus\audience-annotations\0.5.0\audience-annotations-0.5.0.jar;D:\myreposity\log4j\log4j\1.2.17\log4j-1.2.17.jar;D:\myreposity\commons-beanutils\commons-beanutils\1.9.4\commons-beanutils-1.9.4.jar;D:\myreposity\commons-logging\commons-logging\1.2\commons-logging-1.2.jar;D:\myreposity\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\myreposity\org\apache\commons\commons-pool2\2.6.2\commons-pool2-2.6.2.jar;D:\myreposity\com\google\code\findbugs\jsr305\3.0.2\jsr305-3.0.2.jar;D:\myreposity\io\github\zqrferrari\logi-log\1.0.6\logi-log-1.0.6.jar;D:\myreposity\org\apache\logging\log4j\log4j-1.2-api\2.16.0\log4j-1.2-api-2.16.0.jar;D:\myreposity\org\apache\logging\log4j\log4j-core\2.16.0\log4j-core-2.16.0.jar;D:\myreposity\org\apache\logging\log4j\log4j-jcl\2.16.0\log4j-jcl-2.16.0.jar;D:\myreposity\org\apache\httpcomponents\httpmime\4.5.13\httpmime-4.5.13.jar;D:\myreposity\org\apache\httpcomponents\httpclient\4.5.13\httpclient-4.5.13.jar;D:\myreposity\org\apache\httpcomponents\fluent-hc\4.5.13\fluent-hc-4.5.13.jar;D:\myreposity\net\sf\dozer\dozer\5.5.1\dozer-5.5.1.jar;D:\myreposity\org\slf4j\jcl-over-slf4j\1.7.30\jcl-over-slf4j-1.7.30.jar;D:\java-project\knowstream-3.0.0\km-extends\km-monitor\target\classes;D:\java-project\knowstream-3.0.0\km-persistence\target\classes;D:\myreposity\org\mariadb\jdbc\mariadb-java-client\3.0.5\mariadb-java-client-3.0.5.jar;D:\myreposity\io\github\zqrferrari\logi-elasticsearch-client\1.0.24\logi-elasticsearch-client-1.0.24.jar;D:\myreposity\org\elasticsearch\elasticsearch\2.3.3\elasticsearch-2.3.3.jar;D:\myreposity\org\apache\lucene\lucene-core\5.5.0\lucene-core-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-backward-codecs\5.5.0\lucene-backward-codecs-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-analyzers-common\5.5.0\lucene-analyzers-common-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-queries\5.5.0\lucene-queries-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-memory\5.5.0\lucene-memory-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-highlighter\5.5.0\lucene-highlighter-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-queryparser\5.5.0\lucene-queryparser-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-sandbox\5.5.0\lucene-sandbox-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-suggest\5.5.0\lucene-suggest-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-misc\5.5.0\lucene-misc-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-join\5.5.0\lucene-join-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-grouping\5.5.0\lucene-grouping-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-spatial\5.5.0\lucene-spatial-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-spatial3d\5.5.0\lucene-spatial3d-5.5.0.jar;D:\myreposity\com\spatial4j\spatial4j\0.5\spatial4j-0.5.jar;D:\myreposity\org\elasticsearch\securesm\1.0\securesm-1.0.jar;D:\myreposity\com\carrotsearch\hppc\0.7.1\hppc-0.7.1.jar;D:\myreposity\joda-time\joda-time\2.8.2\joda-time-2.8.2.jar;D:\myreposity\org\joda\joda-convert\1.2\joda-convert-1.2.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-smile\2.13.5\jackson-dataformat-smile-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-yaml\2.13.5\jackson-dataformat-yaml-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-cbor\2.13.5\jackson-dataformat-cbor-2.13.5.jar;D:\myreposity\io\netty\netty\3.10.5.Final\netty-3.10.5.Final.jar;D:\myreposity\com\ning\compress-lzf\1.0.2\compress-lzf-1.0.2.jar;D:\myreposity\com\tdunning\t-digest\3.0\t-digest-3.0.jar;D:\myreposity\com\twitter\jsr166e\1.1.0\jsr166e-1.1.0.jar;D:\myreposity\com\alibaba\druid\1.0.29\druid-1.0.29.jar;C:\Program Files\Java\jdk1.8.0_161\lib\jconsole.jar;C:\Program Files\Java\jdk1.8.0_161\lib\tools.jar;D:\myreposity\org\nlpcn\elasticsearch-sql\2.3.5.0\elasticsearch-sql-2.3.5.0.jar;D:\myreposity\com\vividsolutions\jts\1.13\jts-1.13.jar;D:\myreposity\org\elasticsearch\client\elasticsearch-rest-client\6.6.2\elasticsearch-rest-client-6.6.2.jar;D:\myreposity\org\apache\httpcomponents\httpcore\4.4.14\httpcore-4.4.14.jar;D:\myreposity\org\apache\httpcomponents\httpasyncclient\4.1.4\httpasyncclient-4.1.4.jar;D:\myreposity\org\apache\httpcomponents\httpcore-nio\4.4.14\httpcore-nio-4.4.14.jar;D:\myreposity\org\apache\commons\commons-lang3\3.10\commons-lang3-3.10.jar;D:\myreposity\javax\servlet\javax.servlet-api\4.0.1\javax.servlet-api-4.0.1.jar;D:\java-project\knowstream-3.0.0\km-core\target\classes;D:\myreposity\org\springframework\spring-web\5.2.12.RELEASE\spring-web-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-test\5.2.12.RELEASE\spring-test-5.2.12.RELEASE.jar;D:\myreposity\javax\annotation\javax.annotation-api\1.3.2\javax.annotation-api-1.3.2.jar;D:\myreposity\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;D:\myreposity\commons-codec\commons-codec\1.13\commons-codec-1.13.jar;D:\myreposity\org\eclipse\jetty\jetty-util\9.4.39.v20210325\jetty-util-9.4.39.v20210325.jar;D:\myreposity\commons-io\commons-io\2.6\commons-io-2.6.jar;D:\myreposity\net\sf\jopt-simple\jopt-simple\5.0.4\jopt-simple-5.0.4.jar;D:\myreposity\com\alibaba\fastjson\1.2.83\fastjson-1.2.83.jar;D:\myreposity\com\fasterxml\jackson\core\jackson-databind\2.11.3\jackson-databind-2.11.3.jar;D:\myreposity\com\fasterxml\jackson\core\jackson-annotations\2.13.5\jackson-annotations-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\core\jackson-core\2.13.5\jackson-core-2.13.5.jar;D:\myreposity\org\apache\kafka\kafka_2.13\2.8.1\kafka_2.13-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-metadata\2.8.1\kafka-metadata-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-raft\2.8.1\kafka-raft-2.8.1.jar;D:\myreposity\net\sourceforge\argparse4j\argparse4j\0.7.0\argparse4j-0.7.0.jar;D:\myreposity\com\fasterxml\jackson\module\jackson-module-scala_2.13\2.13.5\jackson-module-scala_2.13-2.13.5.jar;D:\myreposity\com\thoughtworks\paranamer\paranamer\2.8\paranamer-2.8.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-csv\2.13.5\jackson-dataformat-csv-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.13.5\jackson-datatype-jdk8-2.13.5.jar;D:\myreposity\com\yammer\metrics\metrics-core\2.2.0\metrics-core-2.2.0.jar;D:\myreposity\org\scala-lang\modules\scala-collection-compat_2.13\2.3.0\scala-collection-compat_2.13-2.3.0.jar;D:\myreposity\org\scala-lang\modules\scala-java8-compat_2.13\0.9.1\scala-java8-compat_2.13-0.9.1.jar;D:\myreposity\org\scala-lang\scala-library\2.13.5\scala-library-2.13.5.jar;D:\myreposity\org\scala-lang\scala-reflect\2.13.5\scala-reflect-2.13.5.jar;D:\myreposity\com\typesafe\scala-logging\scala-logging_2.13\3.9.2\scala-logging_2.13-3.9.2.jar;D:\myreposity\commons-cli\commons-cli\1.4\commons-cli-1.4.jar;D:\myreposity\org\apache\kafka\connect-runtime\2.8.1\connect-runtime-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-tools\2.8.1\kafka-tools-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-log4j-appender\2.8.1\kafka-log4j-appender-2.8.1.jar;D:\myreposity\org\apache\kafka\connect-json\2.8.1\connect-json-2.8.1.jar;D:\myreposity\com\fasterxml\jackson\jaxrs\jackson-jaxrs-json-provider\2.13.5\jackson-jaxrs-json-provider-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\jaxrs\jackson-jaxrs-base\2.13.5\jackson-jaxrs-base-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\module\jackson-module-jaxb-annotations\2.13.5\jackson-module-jaxb-annotations-2.13.5.jar;D:\myreposity\org\glassfish\jersey\containers\jersey-container-servlet\2.30.1\jersey-container-servlet-2.30.1.jar;D:\myreposity\org\glassfish\jersey\containers\jersey-container-servlet-core\2.30.1\jersey-container-servlet-core-2.30.1.jar;D:\myreposity\org\glassfish\hk2\external\jakarta.inject\2.6.1\jakarta.inject-2.6.1.jar;D:\myreposity\org\glassfish\jersey\core\jersey-common\2.30.1\jersey-common-2.30.1.jar;D:\myreposity\org\glassfish\hk2\osgi-resource-locator\1.0.3\osgi-resource-locator-1.0.3.jar;D:\myreposity\org\glassfish\jersey\core\jersey-server\2.30.1\jersey-server-2.30.1.jar;D:\myreposity\org\glassfish\jersey\core\jersey-client\2.30.1\jersey-client-2.30.1.jar;D:\myreposity\org\glassfish\jersey\media\jersey-media-jaxb\2.30.1\jersey-media-jaxb-2.30.1.jar;D:\myreposity\jakarta\ws\rs\jakarta.ws.rs-api\2.1.6\jakarta.ws.rs-api-2.1.6.jar;D:\myreposity\org\glassfish\jersey\inject\jersey-hk2\2.30.1\jersey-hk2-2.30.1.jar;D:\myreposity\org\glassfish\hk2\hk2-locator\2.6.1\hk2-locator-2.6.1.jar;D:\myreposity\org\glassfish\hk2\external\aopalliance-repackaged\2.6.1\aopalliance-repackaged-2.6.1.jar;D:\myreposity\org\glassfish\hk2\hk2-api\2.6.1\hk2-api-2.6.1.jar;D:\myreposity\org\glassfish\hk2\hk2-utils\2.6.1\hk2-utils-2.6.1.jar;D:\myreposity\org\javassist\javassist\3.25.0-GA\javassist-3.25.0-GA.jar;D:\myreposity\javax\xml\bind\jaxb-api\2.3.1\jaxb-api-2.3.1.jar;D:\myreposity\javax\activation\javax.activation-api\1.2.0\javax.activation-api-1.2.0.jar;D:\myreposity\javax\activation\activation\1.1.1\activation-1.1.1.jar;D:\myreposity\org\eclipse\jetty\jetty-server\9.4.35.v20201120\jetty-server-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-http\9.4.35.v20201120\jetty-http-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-io\9.4.35.v20201120\jetty-io-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-servlet\9.4.35.v20201120\jetty-servlet-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-security\9.4.35.v20201120\jetty-security-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-util-ajax\9.4.35.v20201120\jetty-util-ajax-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-servlets\9.4.35.v20201120\jetty-servlets-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-continuation\9.4.35.v20201120\jetty-continuation-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-client\9.4.35.v20201120\jetty-client-9.4.35.v20201120.jar;D:\myreposity\org\reflections\reflections\0.9.12\reflections-0.9.12.jar;D:\myreposity\org\apache\maven\maven-artifact\3.8.1\maven-artifact-3.8.1.jar;D:\myreposity\org\codehaus\plexus\plexus-utils\3.2.1\plexus-utils-3.2.1.jar;D:\java-project\knowstream-3.0.0\km-biz\target\classes;D:\myreposity\org\springframework\spring-context\5.2.12.RELEASE\spring-context-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-expression\5.2.12.RELEASE\spring-expression-5.2.12.RELEASE.jar;D:\java-project\knowstream-3.0.0\km-task\target\classes;D:\myreposity\io\github\zqrferrari\logi-job-spring-boot-starter\1.0.23\logi-job-spring-boot-starter-1.0.23.jar;D:\myreposity\org\mybatis\spring\boot\mybatis-spring-boot-starter\2.2.0\mybatis-spring-boot-starter-2.2.0.jar;D:\myreposity\org\mybatis\spring\boot\mybatis-spring-boot-autoconfigure\2.2.0\mybatis-spring-boot-autoconfigure-2.2.0.jar;D:\myreposity\org\mybatis\mybatis\3.5.7\mybatis-3.5.7.jar;D:\myreposity\org\mybatis\mybatis-spring\2.0.6\mybatis-spring-2.0.6.jar;D:\myreposity\com\github\oshi\oshi-core\5.6.1\oshi-core-5.6.1.jar;D:\myreposity\net\java\dev\jna\jna\5.8.0\jna-5.8.0.jar;D:\myreposity\net\java\dev\jna\jna-platform\5.8.0\jna-platform-5.8.0.jar;D:\java-project\knowstream-3.0.0\km-collector\target\classes;D:\myreposity\org\springframework\spring-webmvc\5.2.12.RELEASE\spring-webmvc-5.2.12.RELEASE.jar;D:\java-project\knowstream-3.0.0\km-enterprise\km-ha\target\classes;D:\myreposity\org\apache\kafka\kafka-clients\2.8.1\kafka-clients-2.8.1.jar;D:\myreposity\com\github\luben\zstd-jni\1.4.9-1\zstd-jni-1.4.9-1.jar;D:\myreposity\org\lz4\lz4-java\1.7.1\lz4-java-1.7.1.jar;D:\myreposity\org\xerial\snappy\snappy-java\1.1.8.1\snappy-java-1.1.8.1.jar;D:\myreposity\org\slf4j\slf4j-api\1.7.30\slf4j-api-1.7.30.jar;D:\myreposity\io\springfox\springfox-swagger2\2.9.2\springfox-swagger2-2.9.2.jar;D:\myreposity\io\swagger\swagger-annotations\1.5.21\swagger-annotations-1.5.21.jar;D:\myreposity\io\swagger\swagger-models\1.5.21\swagger-models-1.5.21.jar;D:\myreposity\io\springfox\springfox-spi\2.9.2\springfox-spi-2.9.2.jar;D:\myreposity\io\springfox\springfox-core\2.9.2\springfox-core-2.9.2.jar;D:\myreposity\io\springfox\springfox-schema\2.9.2\springfox-schema-2.9.2.jar;D:\myreposity\io\springfox\springfox-swagger-common\2.9.2\springfox-swagger-common-2.9.2.jar;D:\myreposity\io\springfox\springfox-spring-web\2.9.2\springfox-spring-web-2.9.2.jar;D:\myreposity\com\google\guava\guava\25.0-jre\guava-25.0-jre.jar;D:\myreposity\org\checkerframework\checker-compat-qual\2.0.0\checker-compat-qual-2.0.0.jar;D:\myreposity\com\google\j2objc\j2objc-annotations\1.1\j2objc-annotations-1.1.jar;D:\myreposity\org\codehaus\mojo\animal-sniffer-annotations\1.14\animal-sniffer-annotations-1.14.jar;D:\myreposity\com\fasterxml\classmate\1.5.1\classmate-1.5.1.jar;D:\myreposity\org\springframework\plugin\spring-plugin-core\1.2.0.RELEASE\spring-plugin-core-1.2.0.RELEASE.jar;D:\myreposity\org\springframework\plugin\spring-plugin-metadata\1.2.0.RELEASE\spring-plugin-metadata-1.2.0.RELEASE.jar;D:\myreposity\org\mapstruct\mapstruct\1.2.0.Final\mapstruct-1.2.0.Final.jar;D:\myreposity\io\springfox\springfox-swagger-ui\2.9.2\springfox-swagger-ui-2.9.2.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-web\2.3.7.RELEASE\spring-boot-starter-web-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-starter\2.3.7.RELEASE\spring-boot-starter-2.3.7.RELEASE.jar;D:\myreposity\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;D:\myreposity\org\yaml\snakeyaml\1.26\snakeyaml-1.26.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-json\2.3.7.RELEASE\spring-boot-starter-json-2.3.7.RELEASE.jar;D:\myreposity\com\fasterxml\jackson\module\jackson-module-parameter-names\2.13.5\jackson-module-parameter-names-2.13.5.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-tomcat\2.3.7.RELEASE\spring-boot-starter-tomcat-2.3.7.RELEASE.jar;D:\myreposity\org\apache\tomcat\embed\tomcat-embed-core\9.0.41\tomcat-embed-core-9.0.41.jar;D:\myreposity\org\apache\tomcat\embed\tomcat-embed-websocket\9.0.41\tomcat-embed-websocket-9.0.41.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-aop\2.3.7.RELEASE\spring-boot-starter-aop-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\spring-aop\5.2.12.RELEASE\spring-aop-5.2.12.RELEASE.jar;D:\myreposity\org\aspectj\aspectjweaver\1.9.6\aspectjweaver-1.9.6.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-logging\2.3.7.RELEASE\spring-boot-starter-logging-2.3.7.RELEASE.jar;D:\myreposity\ch\qos\logback\logback-classic\1.2.8\logback-classic-1.2.8.jar;D:\myreposity\ch\qos\logback\logback-core\1.2.8\logback-core-1.2.8.jar;D:\myreposity\org\apache\logging\log4j\log4j-to-slf4j\2.16.0\log4j-to-slf4j-2.16.0.jar;D:\myreposity\org\apache\logging\log4j\log4j-api\2.16.0\log4j-api-2.16.0.jar;D:\myreposity\org\slf4j\jul-to-slf4j\1.7.30\jul-to-slf4j-1.7.30.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-thymeleaf\2.3.7.RELEASE\spring-boot-starter-thymeleaf-2.3.7.RELEASE.jar;D:\myreposity\org\thymeleaf\thymeleaf-spring5\3.0.11.RELEASE\thymeleaf-spring5-3.0.11.RELEASE.jar;D:\myreposity\org\thymeleaf\thymeleaf\3.0.11.RELEASE\thymeleaf-3.0.11.RELEASE.jar;D:\myreposity\org\attoparser\attoparser\2.0.5.RELEASE\attoparser-2.0.5.RELEASE.jar;D:\myreposity\org\unbescape\unbescape\1.1.6.RELEASE\unbescape-1.1.6.RELEASE.jar;D:\myreposity\org\thymeleaf\extras\thymeleaf-extras-java8time\3.0.4.RELEASE\thymeleaf-extras-java8time-3.0.4.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-validation\2.3.7.RELEASE\spring-boot-starter-validation-2.3.7.RELEASE.jar;D:\myreposity\org\glassfish\jakarta.el\3.0.3\jakarta.el-3.0.3.jar;D:\myreposity\org\hibernate\validator\hibernate-validator\6.1.6.Final\hibernate-validator-6.1.6.Final.jar;D:\myreposity\jakarta\validation\jakarta.validation-api\2.0.2\jakarta.validation-api-2.0.2.jar;D:\myreposity\org\jboss\logging\jboss-logging\3.4.1.Final\jboss-logging-3.4.1.Final.jar;D:\myreposity\jakarta\xml\bind\jakarta.xml.bind-api\2.3.3\jakarta.xml.bind-api-2.3.3.jar;D:\myreposity\jakarta\activation\jakarta.activation-api\1.2.2\jakarta.activation-api-1.2.2.jar;D:\myreposity\net\bytebuddy\byte-buddy\1.10.18\byte-buddy-1.10.18.jar;D:\myreposity\org\springframework\spring-core\5.2.12.RELEASE\spring-core-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-jcl\5.2.12.RELEASE\spring-jcl-5.2.12.RELEASE.jar;D:\myreposity\io\dropwizard\metrics\metrics-core\4.1.2\metrics-core-4.1.2.jar;D:\myreposity\com\github\ben-manes\caffeine\caffeine\2.8.8\caffeine-2.8.8.jar;D:\myreposity\org\checkerframework\checker-qual\3.8.0\checker-qual-3.8.0.jar;D:\myreposity\com\google\errorprone\error_prone_annotations\2.4.0\error_prone_annotations-2.4.0.jar;D:\myreposity\org\springframework\spring-context-support\5.3.19\spring-context-support-5.3.19.jar;D:\myreposity\org\springframework\spring-beans\5.2.12.RELEASE\spring-beans-5.2.12.RELEASE.jar;D:\myreposity\io\github\zqrferrari\logi-security-spring-boot-starter\2.10.13\logi-security-spring-boot-starter-2.10.13.jar;D:\myreposity\com\baomidou\mybatis-plus-boot-starter\3.4.2\mybatis-plus-boot-starter-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus\3.4.2\mybatis-plus-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus-extension\3.4.2\mybatis-plus-extension-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus-core\3.4.2\mybatis-plus-core-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus-annotation\3.4.2\mybatis-plus-annotation-3.4.2.jar;D:\myreposity\com\github\jsqlparser\jsqlparser\4.0\jsqlparser-4.0.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-jdbc\2.3.7.RELEASE\spring-boot-starter-jdbc-2.3.7.RELEASE.jar;D:\myreposity\com\zaxxer\HikariCP\3.4.5\HikariCP-3.4.5.jar;D:\myreposity\org\springframework\spring-jdbc\5.2.12.RELEASE\spring-jdbc-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-tx\5.2.12.RELEASE\spring-tx-5.2.12.RELEASE.jar;D:\myreposity\io\micrometer\micrometer-registry-prometheus\1.5.4\micrometer-registry-prometheus-1.5.4.jar;D:\myreposity\io\micrometer\micrometer-core\1.5.4\micrometer-core-1.5.4.jar;D:\myreposity\org\hdrhistogram\HdrHistogram\2.1.12\HdrHistogram-2.1.12.jar;D:\myreposity\org\latencyutils\LatencyUtils\2.0.3\LatencyUtils-2.0.3.jar;D:\myreposity\io\prometheus\simpleclient_common\0.8.1\simpleclient_common-0.8.1.jar;D:\myreposity\io\prometheus\simpleclient\0.8.1\simpleclient-0.8.1.jar;D:\myreposity\org\springframework\boot\spring-boot-actuator-autoconfigure\2.3.7.RELEASE\spring-boot-actuator-autoconfigure-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-actuator\2.3.7.RELEASE\spring-boot-actuator-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot\2.3.7.RELEASE\spring-boot-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-autoconfigure\2.3.7.RELEASE\spring-boot-autoconfigure-2.3.7.RELEASE.jar;D:\myreposity\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.13.5\jackson-datatype-jsr310-2.13.5.jar;D:\Program Files\JetBrains\IntelliJ IDEA Community Edition 2023.1\lib\idea_rt.jar" com.xiaojukeji.know.streaming.km.rest.KnowStreaming
Connected to the target VM, address: '127.0.0.1:56832', transport: 'socket'
09:27:08.733 [main] INFO com.xiaojukeji.know.streaming.km.rest.KnowStreaming - 192.168.240.42 --> true
09:27:08.791 [main] INFO org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
09:27:10.940 [main] INFO kafka.utils.Log4jControllerRegistration$ - Registered kafka:type=kafka.Log4jController MBean
09:27:11.428 [main] INFO kafka.zookeeper.ZooKeeperClient - [ZooKeeperClient KS-ZK-ClusterPhyId-1] Initializing a new session to 192.168.240.15:2181.
09:27:11.452 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.5.7-f0fdd52973d373ffd9c86b81d99842dc2c7f660e, built on 02/10/2020 11:30 GMT
09:27:11.452 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=ngulasi-hello
09:27:11.452 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_161
09:27:11.452 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation
09:27:11.452 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=C:\Program Files\Java\jdk1.8.0_161\jre
09:27:11.452 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=C:\Program Files\Java\jdk1.8.0_161\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_161\jre\lib\rt.jar;D:\java-project\knowstream-3.0.0\km-rest\target\classes;D:\java-project\knowstream-3.0.0\km-extends\km-account\target\classes;D:\java-project\knowstream-3.0.0\km-common\target\classes;D:\myreposity\org\apache\zookeeper\zookeeper\3.5.7\zookeeper-3.5.7.jar;D:\myreposity\org\apache\zookeeper\zookeeper-jute\3.5.7\zookeeper-jute-3.5.7.jar;D:\myreposity\org\apache\yetus\audience-annotations\0.5.0\audience-annotations-0.5.0.jar;D:\myreposity\log4j\log4j\1.2.17\log4j-1.2.17.jar;D:\myreposity\commons-beanutils\commons-beanutils\1.9.4\commons-beanutils-1.9.4.jar;D:\myreposity\commons-logging\commons-logging\1.2\commons-logging-1.2.jar;D:\myreposity\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\myreposity\org\apache\commons\commons-pool2\2.6.2\commons-pool2-2.6.2.jar;D:\myreposity\com\google\code\findbugs\jsr305\3.0.2\jsr305-3.0.2.jar;D:\myreposity\io\github\zqrferrari\logi-log\1.0.6\logi-log-1.0.6.jar;D:\myreposity\org\apache\logging\log4j\log4j-1.2-api\2.16.0\log4j-1.2-api-2.16.0.jar;D:\myreposity\org\apache\logging\log4j\log4j-core\2.16.0\log4j-core-2.16.0.jar;D:\myreposity\org\apache\logging\log4j\log4j-jcl\2.16.0\log4j-jcl-2.16.0.jar;D:\myreposity\org\apache\httpcomponents\httpmime\4.5.13\httpmime-4.5.13.jar;D:\myreposity\org\apache\httpcomponents\httpclient\4.5.13\httpclient-4.5.13.jar;D:\myreposity\org\apache\httpcomponents\fluent-hc\4.5.13\fluent-hc-4.5.13.jar;D:\myreposity\net\sf\dozer\dozer\5.5.1\dozer-5.5.1.jar;D:\myreposity\org\slf4j\jcl-over-slf4j\1.7.30\jcl-over-slf4j-1.7.30.jar;D:\java-project\knowstream-3.0.0\km-extends\km-monitor\target\classes;D:\java-project\knowstream-3.0.0\km-persistence\target\classes;D:\myreposity\org\mariadb\jdbc\mariadb-java-client\3.0.5\mariadb-java-client-3.0.5.jar;D:\myreposity\io\github\zqrferrari\logi-elasticsearch-client\1.0.24\logi-elasticsearch-client-1.0.24.jar;D:\myreposity\org\elasticsearch\elasticsearch\2.3.3\elasticsearch-2.3.3.jar;D:\myreposity\org\apache\lucene\lucene-core\5.5.0\lucene-core-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-backward-codecs\5.5.0\lucene-backward-codecs-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-analyzers-common\5.5.0\lucene-analyzers-common-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-queries\5.5.0\lucene-queries-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-memory\5.5.0\lucene-memory-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-highlighter\5.5.0\lucene-highlighter-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-queryparser\5.5.0\lucene-queryparser-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-sandbox\5.5.0\lucene-sandbox-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-suggest\5.5.0\lucene-suggest-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-misc\5.5.0\lucene-misc-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-join\5.5.0\lucene-join-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-grouping\5.5.0\lucene-grouping-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-spatial\5.5.0\lucene-spatial-5.5.0.jar;D:\myreposity\org\apache\lucene\lucene-spatial3d\5.5.0\lucene-spatial3d-5.5.0.jar;D:\myreposity\com\spatial4j\spatial4j\0.5\spatial4j-0.5.jar;D:\myreposity\org\elasticsearch\securesm\1.0\securesm-1.0.jar;D:\myreposity\com\carrotsearch\hppc\0.7.1\hppc-0.7.1.jar;D:\myreposity\joda-time\joda-time\2.8.2\joda-time-2.8.2.jar;D:\myreposity\org\joda\joda-convert\1.2\joda-convert-1.2.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-smile\2.13.5\jackson-dataformat-smile-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-yaml\2.13.5\jackson-dataformat-yaml-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-cbor\2.13.5\jackson-dataformat-cbor-2.13.5.jar;D:\myreposity\io\netty\netty\3.10.5.Final\netty-3.10.5.Final.jar;D:\myreposity\com\ning\compress-lzf\1.0.2\compress-lzf-1.0.2.jar;D:\myreposity\com\tdunning\t-digest\3.0\t-digest-3.0.jar;D:\myreposity\com\twitter\jsr166e\1.1.0\jsr166e-1.1.0.jar;D:\myreposity\com\alibaba\druid\1.0.29\druid-1.0.29.jar;C:\Program Files\Java\jdk1.8.0_161\lib\jconsole.jar;C:\Program Files\Java\jdk1.8.0_161\lib\tools.jar;D:\myreposity\org\nlpcn\elasticsearch-sql\2.3.5.0\elasticsearch-sql-2.3.5.0.jar;D:\myreposity\com\vividsolutions\jts\1.13\jts-1.13.jar;D:\myreposity\org\elasticsearch\client\elasticsearch-rest-client\6.6.2\elasticsearch-rest-client-6.6.2.jar;D:\myreposity\org\apache\httpcomponents\httpcore\4.4.14\httpcore-4.4.14.jar;D:\myreposity\org\apache\httpcomponents\httpasyncclient\4.1.4\httpasyncclient-4.1.4.jar;D:\myreposity\org\apache\httpcomponents\httpcore-nio\4.4.14\httpcore-nio-4.4.14.jar;D:\myreposity\org\apache\commons\commons-lang3\3.10\commons-lang3-3.10.jar;D:\myreposity\javax\servlet\javax.servlet-api\4.0.1\javax.servlet-api-4.0.1.jar;D:\java-project\knowstream-3.0.0\km-core\target\classes;D:\myreposity\org\springframework\spring-web\5.2.12.RELEASE\spring-web-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-test\5.2.12.RELEASE\spring-test-5.2.12.RELEASE.jar;D:\myreposity\javax\annotation\javax.annotation-api\1.3.2\javax.annotation-api-1.3.2.jar;D:\myreposity\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;D:\myreposity\commons-codec\commons-codec\1.13\commons-codec-1.13.jar;D:\myreposity\org\eclipse\jetty\jetty-util\9.4.39.v20210325\jetty-util-9.4.39.v20210325.jar;D:\myreposity\commons-io\commons-io\2.6\commons-io-2.6.jar;D:\myreposity\net\sf\jopt-simple\jopt-simple\5.0.4\jopt-simple-5.0.4.jar;D:\myreposity\com\alibaba\fastjson\1.2.83\fastjson-1.2.83.jar;D:\myreposity\com\fasterxml\jackson\core\jackson-databind\2.11.3\jackson-databind-2.11.3.jar;D:\myreposity\com\fasterxml\jackson\core\jackson-annotations\2.13.5\jackson-annotations-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\core\jackson-core\2.13.5\jackson-core-2.13.5.jar;D:\myreposity\org\apache\kafka\kafka_2.13\2.8.1\kafka_2.13-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-metadata\2.8.1\kafka-metadata-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-raft\2.8.1\kafka-raft-2.8.1.jar;D:\myreposity\net\sourceforge\argparse4j\argparse4j\0.7.0\argparse4j-0.7.0.jar;D:\myreposity\com\fasterxml\jackson\module\jackson-module-scala_2.13\2.13.5\jackson-module-scala_2.13-2.13.5.jar;D:\myreposity\com\thoughtworks\paranamer\paranamer\2.8\paranamer-2.8.jar;D:\myreposity\com\fasterxml\jackson\dataformat\jackson-dataformat-csv\2.13.5\jackson-dataformat-csv-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.13.5\jackson-datatype-jdk8-2.13.5.jar;D:\myreposity\com\yammer\metrics\metrics-core\2.2.0\metrics-core-2.2.0.jar;D:\myreposity\org\scala-lang\modules\scala-collection-compat_2.13\2.3.0\scala-collection-compat_2.13-2.3.0.jar;D:\myreposity\org\scala-lang\modules\scala-java8-compat_2.13\0.9.1\scala-java8-compat_2.13-0.9.1.jar;D:\myreposity\org\scala-lang\scala-library\2.13.5\scala-library-2.13.5.jar;D:\myreposity\org\scala-lang\scala-reflect\2.13.5\scala-reflect-2.13.5.jar;D:\myreposity\com\typesafe\scala-logging\scala-logging_2.13\3.9.2\scala-logging_2.13-3.9.2.jar;D:\myreposity\commons-cli\commons-cli\1.4\commons-cli-1.4.jar;D:\myreposity\org\apache\kafka\connect-runtime\2.8.1\connect-runtime-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-tools\2.8.1\kafka-tools-2.8.1.jar;D:\myreposity\org\apache\kafka\kafka-log4j-appender\2.8.1\kafka-log4j-appender-2.8.1.jar;D:\myreposity\org\apache\kafka\connect-json\2.8.1\connect-json-2.8.1.jar;D:\myreposity\com\fasterxml\jackson\jaxrs\jackson-jaxrs-json-provider\2.13.5\jackson-jaxrs-json-provider-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\jaxrs\jackson-jaxrs-base\2.13.5\jackson-jaxrs-base-2.13.5.jar;D:\myreposity\com\fasterxml\jackson\module\jackson-module-jaxb-annotations\2.13.5\jackson-module-jaxb-annotations-2.13.5.jar;D:\myreposity\org\glassfish\jersey\containers\jersey-container-servlet\2.30.1\jersey-container-servlet-2.30.1.jar;D:\myreposity\org\glassfish\jersey\containers\jersey-container-servlet-core\2.30.1\jersey-container-servlet-core-2.30.1.jar;D:\myreposity\org\glassfish\hk2\external\jakarta.inject\2.6.1\jakarta.inject-2.6.1.jar;D:\myreposity\org\glassfish\jersey\core\jersey-common\2.30.1\jersey-common-2.30.1.jar;D:\myreposity\org\glassfish\hk2\osgi-resource-locator\1.0.3\osgi-resource-locator-1.0.3.jar;D:\myreposity\org\glassfish\jersey\core\jersey-server\2.30.1\jersey-server-2.30.1.jar;D:\myreposity\org\glassfish\jersey\core\jersey-client\2.30.1\jersey-client-2.30.1.jar;D:\myreposity\org\glassfish\jersey\media\jersey-media-jaxb\2.30.1\jersey-media-jaxb-2.30.1.jar;D:\myreposity\jakarta\ws\rs\jakarta.ws.rs-api\2.1.6\jakarta.ws.rs-api-2.1.6.jar;D:\myreposity\org\glassfish\jersey\inject\jersey-hk2\2.30.1\jersey-hk2-2.30.1.jar;D:\myreposity\org\glassfish\hk2\hk2-locator\2.6.1\hk2-locator-2.6.1.jar;D:\myreposity\org\glassfish\hk2\external\aopalliance-repackaged\2.6.1\aopalliance-repackaged-2.6.1.jar;D:\myreposity\org\glassfish\hk2\hk2-api\2.6.1\hk2-api-2.6.1.jar;D:\myreposity\org\glassfish\hk2\hk2-utils\2.6.1\hk2-utils-2.6.1.jar;D:\myreposity\org\javassist\javassist\3.25.0-GA\javassist-3.25.0-GA.jar;D:\myreposity\javax\xml\bind\jaxb-api\2.3.1\jaxb-api-2.3.1.jar;D:\myreposity\javax\activation\javax.activation-api\1.2.0\javax.activation-api-1.2.0.jar;D:\myreposity\javax\activation\activation\1.1.1\activation-1.1.1.jar;D:\myreposity\org\eclipse\jetty\jetty-server\9.4.35.v20201120\jetty-server-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-http\9.4.35.v20201120\jetty-http-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-io\9.4.35.v20201120\jetty-io-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-servlet\9.4.35.v20201120\jetty-servlet-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-security\9.4.35.v20201120\jetty-security-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-util-ajax\9.4.35.v20201120\jetty-util-ajax-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-servlets\9.4.35.v20201120\jetty-servlets-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-continuation\9.4.35.v20201120\jetty-continuation-9.4.35.v20201120.jar;D:\myreposity\org\eclipse\jetty\jetty-client\9.4.35.v20201120\jetty-client-9.4.35.v20201120.jar;D:\myreposity\org\reflections\reflections\0.9.12\reflections-0.9.12.jar;D:\myreposity\org\apache\maven\maven-artifact\3.8.1\maven-artifact-3.8.1.jar;D:\myreposity\org\codehaus\plexus\plexus-utils\3.2.1\plexus-utils-3.2.1.jar;D:\java-project\knowstream-3.0.0\km-biz\target\classes;D:\myreposity\org\springframework\spring-context\5.2.12.RELEASE\spring-context-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-expression\5.2.12.RELEASE\spring-expression-5.2.12.RELEASE.jar;D:\java-project\knowstream-3.0.0\km-task\target\classes;D:\myreposity\io\github\zqrferrari\logi-job-spring-boot-starter\1.0.23\logi-job-spring-boot-starter-1.0.23.jar;D:\myreposity\org\mybatis\spring\boot\mybatis-spring-boot-starter\2.2.0\mybatis-spring-boot-starter-2.2.0.jar;D:\myreposity\org\mybatis\spring\boot\mybatis-spring-boot-autoconfigure\2.2.0\mybatis-spring-boot-autoconfigure-2.2.0.jar;D:\myreposity\org\mybatis\mybatis\3.5.7\mybatis-3.5.7.jar;D:\myreposity\org\mybatis\mybatis-spring\2.0.6\mybatis-spring-2.0.6.jar;D:\myreposity\com\github\oshi\oshi-core\5.6.1\oshi-core-5.6.1.jar;D:\myreposity\net\java\dev\jna\jna\5.8.0\jna-5.8.0.jar;D:\myreposity\net\java\dev\jna\jna-platform\5.8.0\jna-platform-5.8.0.jar;D:\java-project\knowstream-3.0.0\km-collector\target\classes;D:\myreposity\org\springframework\spring-webmvc\5.2.12.RELEASE\spring-webmvc-5.2.12.RELEASE.jar;D:\java-project\knowstream-3.0.0\km-enterprise\km-ha\target\classes;D:\myreposity\org\apache\kafka\kafka-clients\2.8.1\kafka-clients-2.8.1.jar;D:\myreposity\com\github\luben\zstd-jni\1.4.9-1\zstd-jni-1.4.9-1.jar;D:\myreposity\org\lz4\lz4-java\1.7.1\lz4-java-1.7.1.jar;D:\myreposity\org\xerial\snappy\snappy-java\1.1.8.1\snappy-java-1.1.8.1.jar;D:\myreposity\org\slf4j\slf4j-api\1.7.30\slf4j-api-1.7.30.jar;D:\myreposity\io\springfox\springfox-swagger2\2.9.2\springfox-swagger2-2.9.2.jar;D:\myreposity\io\swagger\swagger-annotations\1.5.21\swagger-annotations-1.5.21.jar;D:\myreposity\io\swagger\swagger-models\1.5.21\swagger-models-1.5.21.jar;D:\myreposity\io\springfox\springfox-spi\2.9.2\springfox-spi-2.9.2.jar;D:\myreposity\io\springfox\springfox-core\2.9.2\springfox-core-2.9.2.jar;D:\myreposity\io\springfox\springfox-schema\2.9.2\springfox-schema-2.9.2.jar;D:\myreposity\io\springfox\springfox-swagger-common\2.9.2\springfox-swagger-common-2.9.2.jar;D:\myreposity\io\springfox\springfox-spring-web\2.9.2\springfox-spring-web-2.9.2.jar;D:\myreposity\com\google\guava\guava\25.0-jre\guava-25.0-jre.jar;D:\myreposity\org\checkerframework\checker-compat-qual\2.0.0\checker-compat-qual-2.0.0.jar;D:\myreposity\com\google\j2objc\j2objc-annotations\1.1\j2objc-annotations-1.1.jar;D:\myreposity\org\codehaus\mojo\animal-sniffer-annotations\1.14\animal-sniffer-annotations-1.14.jar;D:\myreposity\com\fasterxml\classmate\1.5.1\classmate-1.5.1.jar;D:\myreposity\org\springframework\plugin\spring-plugin-core\1.2.0.RELEASE\spring-plugin-core-1.2.0.RELEASE.jar;D:\myreposity\org\springframework\plugin\spring-plugin-metadata\1.2.0.RELEASE\spring-plugin-metadata-1.2.0.RELEASE.jar;D:\myreposity\org\mapstruct\mapstruct\1.2.0.Final\mapstruct-1.2.0.Final.jar;D:\myreposity\io\springfox\springfox-swagger-ui\2.9.2\springfox-swagger-ui-2.9.2.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-web\2.3.7.RELEASE\spring-boot-starter-web-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-starter\2.3.7.RELEASE\spring-boot-starter-2.3.7.RELEASE.jar;D:\myreposity\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;D:\myreposity\org\yaml\snakeyaml\1.26\snakeyaml-1.26.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-json\2.3.7.RELEASE\spring-boot-starter-json-2.3.7.RELEASE.jar;D:\myreposity\com\fasterxml\jackson\module\jackson-module-parameter-names\2.13.5\jackson-module-parameter-names-2.13.5.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-tomcat\2.3.7.RELEASE\spring-boot-starter-tomcat-2.3.7.RELEASE.jar;D:\myreposity\org\apache\tomcat\embed\tomcat-embed-core\9.0.41\tomcat-embed-core-9.0.41.jar;D:\myreposity\org\apache\tomcat\embed\tomcat-embed-websocket\9.0.41\tomcat-embed-websocket-9.0.41.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-aop\2.3.7.RELEASE\spring-boot-starter-aop-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\spring-aop\5.2.12.RELEASE\spring-aop-5.2.12.RELEASE.jar;D:\myreposity\org\aspectj\aspectjweaver\1.9.6\aspectjweaver-1.9.6.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-logging\2.3.7.RELEASE\spring-boot-starter-logging-2.3.7.RELEASE.jar;D:\myreposity\ch\qos\logback\logback-classic\1.2.8\logback-classic-1.2.8.jar;D:\myreposity\ch\qos\logback\logback-core\1.2.8\logback-core-1.2.8.jar;D:\myreposity\org\apache\logging\log4j\log4j-to-slf4j\2.16.0\log4j-to-slf4j-2.16.0.jar;D:\myreposity\org\apache\logging\log4j\log4j-api\2.16.0\log4j-api-2.16.0.jar;D:\myreposity\org\slf4j\jul-to-slf4j\1.7.30\jul-to-slf4j-1.7.30.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-thymeleaf\2.3.7.RELEASE\spring-boot-starter-thymeleaf-2.3.7.RELEASE.jar;D:\myreposity\org\thymeleaf\thymeleaf-spring5\3.0.11.RELEASE\thymeleaf-spring5-3.0.11.RELEASE.jar;D:\myreposity\org\thymeleaf\thymeleaf\3.0.11.RELEASE\thymeleaf-3.0.11.RELEASE.jar;D:\myreposity\org\attoparser\attoparser\2.0.5.RELEASE\attoparser-2.0.5.RELEASE.jar;D:\myreposity\org\unbescape\unbescape\1.1.6.RELEASE\unbescape-1.1.6.RELEASE.jar;D:\myreposity\org\thymeleaf\extras\thymeleaf-extras-java8time\3.0.4.RELEASE\thymeleaf-extras-java8time-3.0.4.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-validation\2.3.7.RELEASE\spring-boot-starter-validation-2.3.7.RELEASE.jar;D:\myreposity\org\glassfish\jakarta.el\3.0.3\jakarta.el-3.0.3.jar;D:\myreposity\org\hibernate\validator\hibernate-validator\6.1.6.Final\hibernate-validator-6.1.6.Final.jar;D:\myreposity\jakarta\validation\jakarta.validation-api\2.0.2\jakarta.validation-api-2.0.2.jar;D:\myreposity\org\jboss\logging\jboss-logging\3.4.1.Final\jboss-logging-3.4.1.Final.jar;D:\myreposity\jakarta\xml\bind\jakarta.xml.bind-api\2.3.3\jakarta.xml.bind-api-2.3.3.jar;D:\myreposity\jakarta\activation\jakarta.activation-api\1.2.2\jakarta.activation-api-1.2.2.jar;D:\myreposity\net\bytebuddy\byte-buddy\1.10.18\byte-buddy-1.10.18.jar;D:\myreposity\org\springframework\spring-core\5.2.12.RELEASE\spring-core-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-jcl\5.2.12.RELEASE\spring-jcl-5.2.12.RELEASE.jar;D:\myreposity\io\dropwizard\metrics\metrics-core\4.1.2\metrics-core-4.1.2.jar;D:\myreposity\com\github\ben-manes\caffeine\caffeine\2.8.8\caffeine-2.8.8.jar;D:\myreposity\org\checkerframework\checker-qual\3.8.0\checker-qual-3.8.0.jar;D:\myreposity\com\google\errorprone\error_prone_annotations\2.4.0\error_prone_annotations-2.4.0.jar;D:\myreposity\org\springframework\spring-context-support\5.3.19\spring-context-support-5.3.19.jar;D:\myreposity\org\springframework\spring-beans\5.2.12.RELEASE\spring-beans-5.2.12.RELEASE.jar;D:\myreposity\io\github\zqrferrari\logi-security-spring-boot-starter\2.10.13\logi-security-spring-boot-starter-2.10.13.jar;D:\myreposity\com\baomidou\mybatis-plus-boot-starter\3.4.2\mybatis-plus-boot-starter-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus\3.4.2\mybatis-plus-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus-extension\3.4.2\mybatis-plus-extension-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus-core\3.4.2\mybatis-plus-core-3.4.2.jar;D:\myreposity\com\baomidou\mybatis-plus-annotation\3.4.2\mybatis-plus-annotation-3.4.2.jar;D:\myreposity\com\github\jsqlparser\jsqlparser\4.0\jsqlparser-4.0.jar;D:\myreposity\org\springframework\boot\spring-boot-starter-jdbc\2.3.7.RELEASE\spring-boot-starter-jdbc-2.3.7.RELEASE.jar;D:\myreposity\com\zaxxer\HikariCP\3.4.5\HikariCP-3.4.5.jar;D:\myreposity\org\springframework\spring-jdbc\5.2.12.RELEASE\spring-jdbc-5.2.12.RELEASE.jar;D:\myreposity\org\springframework\spring-tx\5.2.12.RELEASE\spring-tx-5.2.12.RELEASE.jar;D:\myreposity\io\micrometer\micrometer-registry-prometheus\1.5.4\micrometer-registry-prometheus-1.5.4.jar;D:\myreposity\io\micrometer\micrometer-core\1.5.4\micrometer-core-1.5.4.jar;D:\myreposity\org\hdrhistogram\HdrHistogram\2.1.12\HdrHistogram-2.1.12.jar;D:\myreposity\org\latencyutils\LatencyUtils\2.0.3\LatencyUtils-2.0.3.jar;D:\myreposity\io\prometheus\simpleclient_common\0.8.1\simpleclient_common-0.8.1.jar;D:\myreposity\io\prometheus\simpleclient\0.8.1\simpleclient-0.8.1.jar;D:\myreposity\org\springframework\boot\spring-boot-actuator-autoconfigure\2.3.7.RELEASE\spring-boot-actuator-autoconfigure-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-actuator\2.3.7.RELEASE\spring-boot-actuator-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot\2.3.7.RELEASE\spring-boot-2.3.7.RELEASE.jar;D:\myreposity\org\springframework\boot\spring-boot-autoconfigure\2.3.7.RELEASE\spring-boot-autoconfigure-2.3.7.RELEASE.jar;D:\myreposity\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.13.5\jackson-datatype-jsr310-2.13.5.jar;D:\Program Files\JetBrains\IntelliJ IDEA Community Edition 2023.1\lib\idea_rt.jar;C:\Users\admin\AppData\Local\JetBrains\IdeaIC2023.2\captureAgent\debugger-agent.jar
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=C:\Program Files\Java\jdk1.8.0_161\bin;C:\WINDOWS\Sun\Java\bin;C:\WINDOWS\system32;C:\WINDOWS;C:\Program Files\Java\jdk1.8.0_161\bin;C:\Program Files\Java\jdk1.8.0_161\jre\bin;C:\ProgramData\Oracle\Java\javapath;C:\WINDOWS\system32;C:\WINDOWS;C:\WINDOWS\System32\Wbem;C:\WINDOWS\System32\WindowsPowerShell\v1.0\;C:\WINDOWS\System32\OpenSSH\;C:\Program Files\nodejs\;D:\Program Files\apache-maven-3.5.3\bin;C:\Program Files\nodejs;D:\Program Files (x86)\NetSarang\Xshell 7\;D:\nodejs\node_global;D:\gradle-7.4.2\bin;D:\TDM-GCC-64\bin;C:\Program Files\dotnet\;E:\Program Files\Kubernetes\Minikube;D:\Program Files\netcat;C:\Program Files\Docker\Docker\resources\bin;C:\ProgramData\DockerDesktop\version-bin;D:\Program Files\hugo\bin;E:\istio-1.15.1\bin;D:\Program Files\protoc-21.7\bin;D:\Program Files\groovy-4.0.6\bin;D:\Program Files (x86)\Go\bin;C:\WINDOWS\system32;C:\WINDOWS;C:\WINDOWS\System32\Wbem;C:\WINDOWS\System32\WindowsPowerShell\v1.0\;C:\WINDOWS\System32\OpenSSH\;C:\Program Files\Git\cmd;C:\Program Files\SourceGear\Common\DiffMerge\;E:\Program Files\python\Scripts\;E:\Program Files\python\;C:\Users\admin\AppData\Local\Microsoft\WindowsApps;;C:\Users\admin\AppData\Local\Programs\Microsoft VS Code\bin;C:\Users\admin\go\bin;C:\Users\admin\AppData\Roaming\npm;E:\Program Files\JetBrains\PyCharm Community Edition 2022.3.2\bin;C:\Users\admin\AppData\Local\Microsoft\WindowsApps;.
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=C:\Users\admin\AppData\Local\Temp\
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Windows 10
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=10.0
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=admin
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=C:\Users\admin
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=D:\java-project\knowstream-3.0.0
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=230MB
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=3572MB
09:27:11.453 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=241MB
09:27:11.460 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=192.168.240.15:2181 sessionTimeout=15000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@465232e9
09:27:12.062 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 4194304 Bytes
09:27:12.078 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 15000. feature enabled=
09:27:12.087 [main] DEBUG kafka.utils.KafkaScheduler - Initializing task scheduler.
09:27:12.089 [main] INFO kafka.zookeeper.ZooKeeperClient - [ZooKeeperClient KS-ZK-ClusterPhyId-1] Waiting until connected.
09:27:27.102 [main] INFO kafka.zookeeper.ZooKeeperClient - [ZooKeeperClient KS-ZK-ClusterPhyId-1] Closing.
09:27:27.103 [main] DEBUG kafka.utils.KafkaScheduler - Shutting down task scheduler.
09:27:27.103 [main] DEBUG org.apache.zookeeper.ZooKeeper - Closing session: 0x0
09:27:27.103 [main] DEBUG org.apache.zookeeper.ClientCnxn - Closing client for session: 0x0
09:27:32.074 [main-SendThread(192.168.240.15:2181)] DEBUG org.apache.zookeeper.SaslServerPrincipal - Canonicalized address to 192.168.240.15
09:27:32.076 [main-SendThread(192.168.240.15:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server 192.168.240.15/192.168.240.15:2181. Will not attempt to authenticate using SASL (unknown error)
09:27:32.078 [main-SendThread(192.168.240.15:2181)] WARN org.apache.zookeeper.ClientCnxn - Client session timed out, have not heard from server in 19997ms for sessionid 0x0
09:27:32.078 [main-SendThread(192.168.240.15:2181)] DEBUG org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x0 : Client session timed out, have not heard from server in 19997ms for sessionid 0x0
09:27:32.082 [main-SendThread(192.168.240.15:2181)] DEBUG org.apache.zookeeper.ClientCnxnSocketNIO - Ignoring exception during shutdown input
java.net.SocketException: Socket is not connected
    at sun.nio.ch.Net.translateToSocketException(Net.java:123)
    at sun.nio.ch.Net.translateException(Net.java:157)
    at sun.nio.ch.Net.translateException(Net.java:163)
    at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:401)
    at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:198)
    at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1261)
Caused by: java.nio.channels.NotYetConnectedException: null
    at sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:782)
    at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:399)
    ... 3 common frames omitted
09:27:32.084 [main-SendThread(192.168.240.15:2181)] DEBUG org.apache.zookeeper.ClientCnxnSocketNIO - Ignoring exception during shutdown output
java.net.SocketException: Socket is not connected
    at sun.nio.ch.Net.translateToSocketException(Net.java:123)
    at sun.nio.ch.Net.translateException(Net.java:157)
    at sun.nio.ch.Net.translateException(Net.java:163)
    at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:409)
    at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:205)
    at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1261)
Caused by: java.nio.channels.NotYetConnectedException: null
    at sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:799)
    at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:407)
    ... 3 common frames omitted
09:27:32.202 [main] DEBUG org.apache.zookeeper.ClientCnxn - Disconnecting client for session: 0x0
09:27:32.207 [main-EventThread] DEBUG kafka.zookeeper.ZooKeeperClient - [ZooKeeperClient KS-ZK-ClusterPhyId-1] Received event: WatchedEvent state:Closed type:None path:null
09:27:32.207 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x0 closed
09:27:32.208 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x0
09:27:32.212 [main] INFO kafka.zookeeper.ZooKeeperClient - [ZooKeeperClient KS-ZK-ClusterPhyId-1] Closed.
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
    at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:271)
    at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:125)
    at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1948)
    at kafka.zk.KafkaZkClient.apply(KafkaZkClient.scala)
    at com.xiaojukeji.know.streaming.km.rest.KnowStreaming.main(KnowStreaming.java:40)
Disconnected from the target VM, address: '127.0.0.1:56832', transport: 'socket'

Process finished with exit code 0

niejian commented 7 months ago

将ks 与zk集群处于同一网段，问题解决

didi / KnowStreaming