Kafka を迅速にマスターするための Kafka 起動コマンドの詳細な分析

Kafka 起動コマンドの詳細説明

1. 単一のブローカーを起動します

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

このコマンドは、Kafka ブローカーを起動し、config を使用します。 /server .properties を構成ファイルとして使用します。

2. 複数のブローカーの起動

kafka-server-start.sh config/server-1.properties
kafka-server-start.sh config/server-2.properties
kafka-server-start.sh config/server-3.properties

このコマンドは 3 つの Kafka ブローカーを起動し、config/server-1.properties、config/server -2 を使用します。 property および config/server-3.properties を構成ファイルとして使用します。

3. ZooKeeper の起動

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

このコマンドは、ZooKeeper サーバーを起動し、config/zookeeper.properties を構成ファイルとして使用します。

4. トピックの作成

kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2

このコマンドは、3 つのパーティションと 2 つのレプリケーション要素を持つ test という名前のトピックを作成します。

5. データの生成

kafka-console-producer.sh --topic test

このコマンドは、test トピックにデータを送信するコンソール プロデューサーを開始します。

6. データの消費

kafka-console-consumer.sh --topic test --from-beginning

このコマンドはコンソール コンシューマを起動し、test トピックの先頭からデータを消費します。

7. Kafka の停止

kafka-server-stop.sh

このコマンドは、実行中のすべての Kafka ブローカーを停止します。

8. ZooKeeper の停止

zookeeper-server-stop.sh

このコマンドは、ZooKeeper サーバーを停止します。

具体的なコード例

以下は、Kafka クラスターの開始、トピックの作成、データの生成、データの消費、そして Kafka クラスターの停止方法を示す完全な例です。

# 启动ZooKeeper
zookeeper-server-start.sh config/zookeeper.properties

# 启动Kafka Broker
kafka-server-start.sh config/server-1.properties
kafka-server-start.sh config/server-2.properties
kafka-server-start.sh config/server-3.properties

# 创建Topic
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2

# 生产数据
kafka-console-producer.sh --topic test

# 消费数据
kafka-console-consumer.sh --topic test --from-beginning

# 停止Kafka
kafka-server-stop.sh

# 停止ZooKeeper
zookeeper-server-stop.sh

Notes

• Kafka Broker を起動する前に、まず ZooKeeper サーバーを起動する必要があります。
• トピックを作成する前に、Kafka Broker を起動する必要があります。
• データを生成する前に、まずトピックを作成する必要があります。
• データを使用する前に、まずデータを生成する必要があります。
• Kafka クラスターを停止する前に、まず実行中のすべての Kafka ブローカーを停止する必要があります。
• ZooKeeper サーバーを停止する前に、まず実行中のすべての Kafka ブローカーを停止する必要があります。

以上がKafka を迅速にマスターするための Kafka 起動コマンドの詳細な分析の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。