RHELにKafkaをインストールするためのいくつかのAnsibleを作成していて、サービスが実行されており、ネットワークからサービスにアクセスできるようにファイアウォールを設定しようとしています。 私がリッスンしているポートを見ると見ることが期待されます9092。9093ただし、任意のアドバンストポートに3番目のポートが表示されます。 # ss -lnp | grep java tcp LISTEN 0 50 *:9092 ...
私たちの目標は、Kafkaマシンに200TBの巨大なストレージスペースを使用することです。 この目的を達成するために、RAID10でLVMを使用して4つの物理ディスクにボリュームを作成します。各ディスクサイズは50Tです。 RAID10注 - RAID 10ごとに12個のディスクがある場合、各ディスクは実際にsdb / sdc / sdd / sdeです。 Kafkaサーバーには4つのディスクがあります（例lsblk：）。 sdb 8:16 0 50T 0 disk sdc 8:...
私たちはApache Kafkaサーバーにとって非常に大きな問題に直面しています。 Kafkaサーバーは「ファイルがあまりにも開いています。」 本番 Kafka クラスターがあります。7台、Kafkaのバージョンは次のとおりです。0.1 OSバージョン - RHEL 7.5 私たちは「kafka_user_nofile_limit「到着500000、元の値は128000 しかし、我々は再び高い価格を記録し、ブローカーは崩壊しました また、Kafkaのログに「開いているファイルが多すぎます」という行がたくさんあることは明らかです。 私たちは以下を見ましたギラケ...
ディスクにxfsファイルシステムを作成する必要がありますkafka ディスクの特別な点はkafkaディスクサイズです。 kafka20TB私たちの場合、ディスクのサイズは次のとおりです。 次のことはよくわかりませんが、mkfs次のcliがxfs大容量ディスク（kafkaマシン）にファイルシステムを作成するのに十分かどうかについてのアドバイスが必要です。 DISK=sdb mkfs.xfs -L kafka /dev/$DISK -f カフカのベストプラクティス ファイルシステムの選択 Kafka はディスク上の汎用ファイ...
最新バージョンをインストールしましたが、モジュールrsyslogはありません！これらのモジュールをどのように追加できますか？ありがとうございます。omfwdomkafka ...
KafkaコンシューマツールがDockerのクラスタに接続されていない 注文する docker-compose -f docker-compose.yaml up --force-recreate --remove-orphans Docker Composeコマンドは3つの仮想マシン（zookeeper、、、kafka）を起動しますkafka-create-topics。 3番目の仮想マシンは新しいトピックを作成topicし、ここにメッセージをプッシュしてから使用しようとします。最初の2つのコマンドは機能し、エラーが発生しないようです。ところがk...