kafka开启了SASL验证(端口9094),gohangout使用SASL拉取数据;通过日志查看kafka频繁报出以下内容
WARN Attempting to send response via channel for which there is no open connection, connection id 10.10.110.10:9094-10.10.110.25:34408-290441 (kafka.network.Processor)
同时出现oom异常,大量close_wait连接,组件宕机
ERROR Processor got uncaught exception. (kafka.network.Processor)
java.lang.OutOfMemoryError: Java heap space
ERROR [ExpirationReaper-16-Fetch]: Error due to (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
java.lang.OutOfMemoryError: Java heap space
[ReplicaManager broker=16] Error processing fetch operation on partition test-33, offset 0 (kafka.server.ReplicaManager)
java.lang.OutOfMemoryError: Java heap space
使用9092端口时无任何警告和异常,运行正常。Zookeeper的maxClientCnxns配置项从1000为5000后现象缓解。
请问出现这种问题的原因是什么呢?