Apprenez à utiliser les commandes Kafka courantes et répondez de manière flexible à divers scénarios.

Essentiels pour apprendre Kafka : maîtrisez les commandes courantes et gérez facilement divers scénarios

1 Créer un sujet

bin/kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2

2.

bin/kafka-topics.sh --list

4. Produire des messages

bin/kafka-topics.sh --describe --topic my-topic

5. Consommer des messages

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

6 Changer le nombre de partitions

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

7.

bin/kafka-topics.sh --alter --topic my-topic --partitions 5

9. Créer un groupe de consommateurs

bin/kafka-topics.sh --alter --topic my-topic --replication-factor 3

10. Liste des groupes de consommateurs

bin/kafka-topics.sh --delete --topic my-topic

11. Afficher les détails du groupe de consommateurs

bin/kafka-consumer-groups.sh --create --group my-group

12. Ajouter un consommateur au groupe de consommateurs

bin/kafka-consumer-groups.sh --list

. le consommateur du groupe de consommateurs

bin/kafka-consumer-groups.sh --describe --group my-group

14. Supprimez le groupe de consommateurs

bin/kafka-consumer-groups.sh --join --group my-group --topic my-topic

15. Obtenez le décalage du sujet

bin/kafka-consumer-groups.sh --leave --group my-group --topic my-topic

16. Définissez le décalage du sujet

bin/kafka-consumer-groups.sh --delete --group my-group

17. Cluster Kafka

bin/kafka-run-class kafka.tools.GetOffsetShell --topic my-topic --group my-group

18. Arrêtez le cluster Kafka

bin/kafka-run-class kafka.tools.OffsetResetTool --topic my-topic --group my-group --to-earliest

19 Diagnostiquez le cluster Kafka

bin/kafka-server-start.sh --daemon --console

20. 1. Importer la configuration du cluster Kafka

bin/kafka-server-stop.sh

22. Mettre à niveau le cluster Kafka

bin/kafka-run-class kafka.tools.JmxTool --query "kafka.server:type=*,name=*,clientId=*"

23. Rétrograder le cluster Kafka

bin/kafka-run-class kafka.tools.DumpLogSegments --print-data --source /tmp/kafka-logs

.

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!