Étapes pour créer un sujet Kafka : utilisation des commandes Kafka

Étapes pour créer un sujet à l'aide des commandes Kafka

1. Démarrer ZooKeeper et les services Kafka

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

2. Créer un sujet

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

3. Voir le sujet

kafka-topics.sh --list

4. Envoyer vers le sujet Messages

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

5. Consommez les messages du sujet

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

Exemples de code spécifiques

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

# 启动Kafka服务
kafka-server-start.sh config/server.properties

# 创建主题
kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1

# 查看主题
kafka-topics.sh --list

# 向主题发送消息
kafka-console-producer.sh --topic my-topic --message "Hello, world!"

# 从主题消费消息
kafka-console-consumer.sh --topic my-topic --from-beginning

Notes

• Lors de la création d'un sujet, vous devez spécifier le nom du sujet, le nombre de partitions et nombre de répliques.
• Le nombre de partitions détermine le nombre de messages que le sujet peut gérer simultanément.
• Le nombre de copies détermine le nombre de copies des données du sujet.
• Lors de l'envoi d'un message à un sujet, vous devez spécifier la clé et la valeur du message.
• Lorsque vous consommez des messages d'un sujet, vous pouvez spécifier un groupe de consommateurs. Les consommateurs du groupe de consommateurs consommeront conjointement les messages du sujet.

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!