Analyse approfondie des commandes de démarrage de Kafka pour maîtriser rapidement Kafka

Explication détaillée de la commande de démarrage de Kafka

1. Démarrez un seul courtier

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

Cette commande démarrera un courtier Kafka et utilisera config/server.properties comme fichier de configuration. config/server.properties作为配置文件。

2. 启动多个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

该命令将启动三个Kafka Broker，并使用config/server-1.properties、config/server-2.properties和config/server-3.properties作为配置文件。

3. 启动ZooKeeper

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

该命令将启动一个ZooKeeper服务器，并使用config/zookeeper.properties作为配置文件。

4. 创建Topic

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

该命令将创建一个名为test的Topic，该Topic具有3个分区和2个副本因子。

5. 生产数据

kafka-console-producer.sh --topic test

该命令将启动一个控制台生产者，该生产者将数据发送到test Topic。

6. 消费数据

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

该命令将启动一个控制台消费者，该消费者将从test

2. Démarrez plusieurs courtiers

kafka-server-stop.sh

Cette commande démarrera trois courtiers Kafka et utilisera config/server-1.properties, config/server-2.properties</code > et < code>config/server-3.properties comme fichiers de configuration.

3. Démarrez ZooKeeper

zookeeper-server-stop.sh

Cette commande démarrera un serveur ZooKeeper et utilisera config/zookeeper.properties comme fichier de configuration.

4. Créer un sujet

# 启动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

Cette commande créera un sujet nommé test, qui comporte 3 partitions et 2 facteurs de réplication.

5. Produire des données

rrreee

Cette commande démarrera un producteur de console qui envoie des données au sujet test.

• 6. Consume data
rrreee
• Cette commande démarrera un consommateur de console, qui consommera les données depuis le début du sujet test.
• 7. Arrêtez Kafka
rrreee
• Cette commande arrêtera tous les courtiers Kafka en cours d'exécution.
• 8. Arrêtez ZooKeeper
rrreee
• Cette commande arrêtera le serveur ZooKeeper.

Exemples de code spécifiques🎜🎜Ce qui suit est un exemple complet qui montre comment démarrer un cluster Kafka, créer un sujet, produire des données, consommer des données, puis arrêter le cluster Kafka. 🎜rrreee🎜Notes🎜🎜🎜Avant de démarrer Kafka Broker, vous devez d'abord démarrer le serveur ZooKeeper. 🎜🎜Kafka Broker doit être démarré avant de créer un sujet. 🎜🎜Le sujet doit être créé avant de produire des données. 🎜🎜Avant de consommer des données, les données doivent d'abord être produites. 🎜🎜Avant d'arrêter le cluster Kafka, vous devez d'abord arrêter tous les Kafka Brokers en cours d'exécution. 🎜🎜Avant d'arrêter le serveur ZooKeeper, vous devez d'abord arrêter tous les Kafka Brokers en cours d'exécution. 🎜🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!