小白晒太阳

加了DESCRIBE权限，给上面说的机器A。

authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer

你配认证了？

什么配置，是指kafka 配置吗，在https://www.orchome.com/570有贴过

一分钟一次还好啦。你把你的配置发一下

kafka日志就打印了那一条log，没有错误信息。
我发现了一个可疑的点，我的kafka集群中有2个broker所在的机器存在大量的CLOSE_WAIT。

CLOSE_WAIT 385
ESTABLISHED 8

均来自机器A ，我在机器A上做了这样的事情，每分钟用java去执行bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker -zookeeper ${zk} -topic ${topic} -group ${group}kafka自带的脚本。

感觉像是请求太频繁，kafka broker 连接未释放导致再有新的请求就出问题了。