EricZeng

> 我的zookeeper用的是org.apache.kafka.common.security.plain.PlainLoginModule,其它配置按照文档中进行配置，出现下面报错 2023-06-30 14:26:59.939 [MetadataTaskTP-6-thread-21] ERROR class=c.x.k.s.k.c.utils.zookeeper.FourLetterWordUtil||method=executeFourLetterCmd||clusterPhyId=2||host=192.168.22.123||port=2181||cmd=srvr||secure=true||timeout=5000||errMsg=exception! javax.net.ssl.SSLHandshakeException: Remote host terminated the handshake at sun.security.ssl.SSLSocketImpl.handleEOF(SSLSocketImpl.java:1379) at sun.security.ssl.SSLSocketImpl.decode(SSLSocketImpl.java:1206) at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(SSLSocketImpl.java:1107) at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:400) at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:372) at com.xiaojukeji.know.streaming.km.common.utils.zookeeper.FourLetterWordUtil.send4LetterWord(FourLetterWordUtil.java:94) at com.xiaojukeji.know.streaming.km.common.utils.zookeeper.FourLetterWordUtil.executeFourLetterCmd(FourLetterWordUtil.java:48) at com.xiaojukeji.know.streaming.km.core.service.zookeeper.impl.ZookeeperServiceImpl.getFromZookeeperCluster(ZookeeperServiceImpl.java:150) at...

>  是KS的一个BUG，后续修复一下，老哥有兴趣的话，也欢迎贡献PR。

> 修改 KnowStreaming 的启动脚本 > > # `KnowStreaming/bin/startup.sh` 中的 47 行的 JAVA_OPT 中追加如下设置 > -Djava.security.auth.login.config=/xxx/zk_client_jaas.conf > > 请问这里采用docker运行的话应该如何配置 对容器不是很了解。 觉得可以参照application.yml这个文件怎么生效的来增加zk_client_jaas.conf这个文件（觉得可以使用ADD命令加进来），先试着看能否成功加进来，然后再在startup.sh里面，增加-Djava.security.auth.login.config=/xxx/zk_client_jaas.conf这个参数。

> * [x] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 > > 你是否希望来认领这个Bug。 > > 「 Y / N 」 > > ### 环境信息 > * KnowStreaming version : 3.3.0 > * Operating System...

> 具体的接口是？然后对应的错误日志是？

> MetricCollect-Shard-1-9-thread-79 1、这个日志不对，这个是采集线程的日志，前端页面是http请求，线程堆栈不是这样的。 2、这个地方出现了：The AdminClient thread has exited 的日志，看看有没有什么日志显示关闭了AdminClient。

> > > MetricCollect-Shard-1-9-thread-79 > > > > > > 1、这个日志不对，这个是采集线程的日志，前端页面是http请求，线程堆栈不是这样的。 2、这个地方出现了：The AdminClient thread has exited 的日志，看看有没有什么日志显示关闭了AdminClient。 > > ### 1.API调用后的错误信息如下 > **API的方法里我加了测试日志，当调用到GroupManagerImpl.pagingGroupTopicConsumedMetrics方法中的groupService.getGroupOffsetFromKafka时，是立即抛出异常报错的,没感觉到有什么什么延时、超时** > > 2023-07-26 18:07:26.829 [ApiCallTP-4-thread-2] ERROR class=c.x.k.s.k.core.service.group.impl.GroupServiceImpl||method=getGroupOffset||clusterPhyId=1|groupName=integration_payment_logs||errMsg=exception!...

说明一下： 1、调用之后马上超时的原因：日志里面有 The AdminClient thread has exited 这个日志，这个表示AdminClient客户端被关闭了，会导致调用直接超时。 2、基于上面的判断，可以看一下有没有什么地方主动关闭了AdminClient。 排查： 1、info的日志里面有 “close kafka AdminClient starting, clusterPhyId:” 这个日志么？ 2、jstack打看看线程都在干嘛，辛苦提供一下。 3、不修改接入KS集群的配置，重启一下KS，看是否还有The AdminClient thread has exited的日志。同时打印一下jstack，运行一段时间之后，如果出现“close kafka AdminClient starting, clusterPhyId:” 这个日志，则再打印一下jstack对比看看。

> 辛苦给一份kafka客户端，在创建KafkaAdminClient前和出现The AdminClient thread has exited日志后的debug日志吧。

> > > > > > > > > 辛苦给一份kafka客户端，在创建KafkaAdminClient前和出现The AdminClient thread has exited日志后的debug日志吧。 > > test.log 2023-07-28 10:13:29.787 是api请求开始 2023-07-28 10:13:29.789 是The AdminClient thread has exited. > > [kafka_client.log](https://github.com/didi/KnowStreaming/files/12192227/kafka_client.log)...