kafka + Kafkaブローカー間またはブローカーとクライアント間で開いているファイルが多すぎる可能性があります。

私たちはApache Kafkaサーバーにとって非常に大きな問題に直面しています。 Kafkaサーバーは「ファイルがあまりにも開いています。」

本番 Kafka クラスターがあります。7台、Kafkaのバージョンは次のとおりです。0.1

OSバージョン - RHEL 7.5

私たちは「kafka_user_nofile_limit「到着500000、元の値は128000

しかし、我々は再び高い価格を記録し、ブローカーは崩壊しました

また、Kafkaのログに「開いているファイルが多すぎます」という行がたくさんあることは明らかです。

私たちは以下を見ましたギラケース

https://issues.apache.org/jira/browse/KAFKA-3317

しかし、私たちはこのJiraの解決策が何であるか、この主な問題に対する解決策が何であるかを知りません。

ギラから

 Bug
Status:OPEN
Priority: Major
Resolution:Unresolved
Affects Version/s:
0.9.0.0, 0.9.0.1
Fix Version/s:None
Component/s:None
Labels:None
Environment:CentOS release 6.5 (Final)
kafka_2.11-0.9.0.1
Flags:
Important
Description
there is much open files in my java app client which write msg to kafka broker, i used

<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.9.0.1</version>
</dependency>
new api to write msg. when i use

lsof -p 8780 | wc -l
19184
lsof -p 8780 | grep XmlIpcRegSvc | wc -l
4920
lsof -p 8780 | grep pipe | wc -l
9576
lsof -p 8780 | grep eventpoll | wc -l
4792
where 8780 is my java app pid.

java 37121 app *796u IPv6 960673997 0t0 TCP mad183:50213->mad180:XmlIpcRegSvc (ESTABLISHED)
there are many ESTABLISHED XmlIpcRegSvc , and seems not closed.
and It likes use ipv6 .


 

私の設定

 more /etc/security/limits.d/kafka.conf

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

kafka   - nofile   500000
kafka   - nproc    65536