この記事は機械翻訳のミラー記事です。元の記事にジャンプするにはこちらをクリックしてください。

Architect_Programmer_Code農業ネットワーク»建築家 › プログラミング › 技術チャット › CentOSはKafkaメッセージミドルウェアを構築します
眺める： 5413|答える： 2

CentOSはKafkaメッセージミドルウェアを構築します

[リンクをコピー]
掲載地 2021/12/12 12:25:22 | | | |
Kafkaは、Apache Software Foundationによって開発されたオープンソースのストリーミングプラットフォームで、ScalaとJavaで書かれています。 Kafkaは、ウェブサイト内の消費者のアクションフローデータを処理する、高スループットの分散型パブリッシュ・サブスクライブメッセージングシステムです。 この行為(ウェブ閲覧、検索、その他のユーザーアクション)は、現代のウェブ上の多くのソーシャル機能において重要な要素です。 このデータは、スループット要件のため、ログ処理やログ集約によって解決されることが多いです。 これはHadoopのようなログデータやオフライン分析システムには有効な解決策ですが、リアルタイム処理の制限が必要です。 Kafkaの目的は、Hadoopの並列ロードメカニズムを通じてオンラインとオフラインのメッセージ処理を統合し、クラスタリングを通じてリアルタイムメッセージを提供することです。

復習：

.NET/C#メッセージキュー用のKafka操作[ソースコード付き]
https://www.itsvse.com/thread-9619-1-1.html

KafkaがJMXリモートモニタリングを設定する
https://www.itsvse.com/thread-9968-1-1.html

まず、私はCentOS 8システムとKafka版を使っています:kafka_2.13-3.0.0。

アンジップコマンドは以下の通りダウンロードできます:

Configure Kafka

/data/middleware/kafka_2.13-3.0.0/configフォルダに行き、それを修正してくださいserver.properties主な修正案は以下の通りです。

ZookeeperとKafkaのローンチ

コマンド開始

停止指令

ZookeeperとKafkaをサービスとして登録してください

/etc/systemd/systemフォルダにアクセスしてください

以下の設定で新しいzookeeper.serviceサービスファイルを作成します:
スタートアップを起動してセットアップします

新しいkafka.serviceサービスファイルを作成し、以下のように設定します:



スタートアップを起動してセットアップします


以下の画像に示されているように、ZookeeperとKafkaのサービスの状況を確認してください:



Kafkaのデフォルト移植版:9092、Zookeeperのデフォルトポート:2181さあ、19988 JMX移植版です!




先の：CentOSシステムデプロイメントのnacosチュートリアル
次に：【実戦】カフカパラメータ調整は、メッセージ本体が大きすぎる問題を解決します

関連記事
 地主| 掲載地 2021/12/24 11:25:13 |
JMXの設定やLinux環境は、以下のように直接 kafka-server-start.sh ファイルを変更することも可能です。

掲載地 2021/12/26 16:58:13 |
学ぶことを学べ。。。。。。
免責事項：
Code Farmer Networkが発行するすべてのソフトウェア、プログラミング資料、記事は学習および研究目的のみを目的としています。 上記の内容は商業的または違法な目的で使用されてはならず、そうでなければ利用者はすべての結果を負うことになります。 このサイトの情報はインターネットからのものであり、著作権紛争はこのサイトとは関係ありません。 ダウンロード後24時間以内に上記の内容を完全にパソコンから削除してください。 もしこのプログラムを気に入ったら、正規のソフトウェアを支持し、登録を購入し、より良い本物のサービスを受けてください。 もし侵害があれば、メールでご連絡ください。
Mail To:help@itsvse.com