Kafka を迅速にマスターするための Kafka 起動コマンドの詳細な分析-＆＃＆チュートリアル-php.cn

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

WBOY

リリース： 2024-02-01 09:44:14

オリジナル

927 人が閲覧しました

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

ログイン後にコピー