Kafka バージョン クエリの使用方法を学習するためのステップバイステップ ガイド

1. Kafka のインストール

• Apache Kafka をダウンロードしてサーバーにインストールします。
• Kafka アーカイブ ファイルを解凍します。
• 環境変数の設定KAFKA_HOME は、Kafka のインストール ディレクトリです。

2. ZooKeeper の起動

• ZooKeeper は Kafka の依存関係であるため、Kafka を起動する前に起動する必要があります。
• コマンド ライン ターミナルを開き、$KAFKA_HOME/bin ディレクトリに移動します。
• 次のコマンドを実行して ZooKeeper を起動します:

./zookeeper-server-start.sh config/zookeeper.properties

3. Kafka サーバーを起動します

• コマンド ライン ターミナルを開きます$KAFKA_HOME/bin ディレクトリに移動します。
• 次のコマンドを実行して Kafka サーバーを起動します:

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

4. トピックの作成

• トピックはKafka におけるデータの論理グループ。
• テーマを作成するには、コマンド ライン ターミナルを開き、$KAFKA_HOME/bin ディレクトリに移動します。
• 次のコマンドを実行してトピックを作成します:

./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1

5. メッセージの送信

• メッセージを送信するにはこのトピックでは、「ターミナルの実行」コマンドを開き、$KAFKA_HOME/bin ディレクトリに移動します。
• 次のコマンドを実行してメッセージを送信します:

./kafka-console-producer.sh --topic my-topic --message "Hello, world!"

6. メッセージの消費

• トピックからのメッセージを消費するには、「ターミナルの実行」コマンドを開き、$KAFKA_HOME/bin ディレクトリに移動します。
• 次のコマンドを実行してメッセージを消費します:

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

7. バージョンをクエリする

• Kafka サーバー。コマンド ライン ターミナルを開いて、$KAFKA_HOME/bin ディレクトリに移動してください。
• 次のコマンドを実行してバージョンを照会します:

./kafka-version.sh

サンプル出力

kafka-version.sh:
 version: 2.8.0
 kafka-version: 2.8.0
 kafka-storage: 2.8.0
 kafka-clients: 2.8.0
 kafka-streams: 2.8.0
 kafka-connect: 2.8.0
 kafka-admin: 2.8.0
 kafka-tools: 2.8.0

以上がKafka バージョン クエリの使用方法を学習するためのステップバイステップ ガイドの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。