Linux に Kafka をインストールするためのクイック ガイド

#タイトル: Linux Kafka インストール チュートリアル: すぐに始める

本文:

1. はじめに

Apache Kafka は、大量のデータを処理し、高スループット、低遅延、および高信頼性を提供できる分散パブリッシュ/サブスクライブ メッセージング システムです。 Kafka は、ログ収集、データ分析、ストリーム処理などの分野で広く使用されています。

2. インストールの準備

オペレーティング システム: Linux (Ubuntu 18.04 以降を推奨)
1. Java: JDK 8 以降のバージョン
2. ZooKeeper: 3.4.14 以降のバージョン
3. Kafka: 2.11 以降のバージョン

3. ZooKeeper のインストール

ZooKeeper をダウンロード: Apache 公式 Web サイトから ZooKeeper バイナリ パッケージをダウンロードします。
1. ZooKeeper を解凍します。ダウンロードしたバイナリ パッケージを指定したディレクトリに解凍します。
3. ZooKeeper の構成: 解凍された ZooKeeper ディレクトリで

   conf/zoo.cfg ファイルを見つけて、次の構成を変更します:

   • dataDir=/path/to/zookeeper/data: ZooKeeper データ ディレクトリ
   • clientPort=2181: ZooKeeper クライアント ポート
ZooKeeper の起動: 次のコマンドを実行して ZooKeeper を起動します:

4. bin/zkServer.sh start

4. Kafka をインストールします

Kafka をダウンロードします: Apache 公式から Kafka バイナリ パッケージをダウンロードします。 Webサイト。
1. Kafka を解凍します: ダウンロードしたバイナリ パッケージを指定されたディレクトリに解凍します。
3. Kafka の構成: 解凍された Kafka ディレクトリで

   config/server.properties ファイルを見つけて、次の構成を変更します:

   • Broker.id=0: Kafka ブローカー ID
   • zookeeper.connect=localhost:2181: ZooKeeper 接続アドレス
   • log.dirs=/path /to/kafka/logs: Kafka ログ ディレクトリ
Kafka の開始: 次のコマンドを実行して Kafka を開始します:

4. bin/kafka-server-start.sh config/server.properties

5トピックの作成

Kafka コマンド ライン ツールを開く: 次のコマンドを実行して、Kafka コマンド ライン ツールを開きます:

1. bin/kafka-console-producer.sh --topic my-topic

トピックを作成する: Kafka コマンド ライン ツールで次のコマンドを入力してトピックを作成します。

2. create my-topic --replication-factor 1 --partitions 1

6. メッセージを送信します。

次のコマンドを入力します。 Kafka コマンド ライン ツールでメッセージを送信します:

send my-topic hello world

7. メッセージを受信します

別の Kafka コマンド ライン ツールを開きます: 次のコマンドを実行します。別の Kafka コマンド ライン ツールを開くコマンド:

1. bin/kafka-console-consumer.sh --topic my-topic --from-beginning

メッセージの受信: 受信したメッセージは Kafka コマンド ライン ツールに表示されます。

8. Kafka の停止

次のコマンドを実行して Kafka を停止します:

1. bin/kafka-server-stop.sh

Run次のコマンド Stop ZooKeeper:

2. bin/zkServer.sh stop

9. 概要

上記の手順により、Linux に Kafka が正常にインストールされました。これで、Kafka を使用してデータの処理を開始できるようになりました。

以上がLinux に Kafka をインストールするためのクイック ガイドの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。