Apache Kafka est un service de file d'attente de messages populaire qui vous aide à créer des applications à haut débit et à faible latence. Si vous devez utiliser Kafka dans votre application, vous devez vous familiariser avec les différentes commandes de Kafka.
Cet article vous fournira un aperçu des commandes Kafka pour vous aider à améliorer rapidement votre efficacité au travail.
kafka-console-producer
: Cette commande vous permet d'envoyer des données à Kafka depuis la ligne de commande. kafka-console-producer
:该命令允许您从命令行向 Kafka 中发送数据。kafka-producer
:该命令允许您使用 Java API 向 Kafka 中发送数据。kafka-console-consumer
:该命令允许您从命令行读取 Kafka 中的数据。kafka-consumer
:该命令允许您使用 Java API 读取 Kafka 中的数据。kafka-topics
:该命令允许您管理 Kafka 中的主题。kafka-brokers
:该命令允许您管理 Kafka 中的代理。kafka-admin
:该命令允许您管理 Kafka 中的集群。kafka-cat
:该命令允许您查看 Kafka 中的消息。kafka-diff
:该命令允许您将 Kafka 中的集群进行差异化。kafka-mirror-topics
:该命令允许您将 Kafka 中的主题镜像到另一个集群。kafka-configs
kafka-producer
: Cette commande vous permet d'envoyer des données à Kafka à l'aide de l'API Java. kafka-console-consumer
: Cette commande vous permet de lire des données dans Kafka à partir de la ligne de commande. kafka-consumer
: Cette commande vous permet de lire les données de Kafka à l'aide de l'API Java. kafka-topics
: Cette commande permet de gérer les sujets dans Kafka. kafka-brokers
: Cette commande vous permet de gérer les courtiers dans Kafka.
kafka-admin
: Cette commande permet de gérer les clusters dans Kafka.
kafka-cat
: Cette commande vous permet d'afficher les messages dans Kafka. 🎜🎜kafka-diff
: Cette commande permet de différencier les clusters dans Kafka. 🎜🎜kafka-mirror-topics
: Cette commande vous permet de mettre en miroir les sujets de Kafka vers un autre cluster. 🎜🎜🎜5. Commande de configuration 🎜🎜🎜kafka-configs
: Cette commande permet de gérer les fichiers de configuration du cluster dans Kafka. 🎜🎜🎜Exemples de commandes spécifiques🎜🎜1. Utilisez kafka-console-producer pour envoyer des données à Kafka🎜bin/kafka-console-producer --broker-list localhost:9092 --producer-property parse.key=true --producer-property key.separator=, --producer-property print.key=true --producer-property value.serializer=StringEncoder --producer-property key.serializer=StringEncoder --producer-config config/producer.config --request-required-ACKS=1
bin/kafka-console-consumer --broker-list localhost:9092 --consumer-property auto.offset.reset=earlies --consumer-property group.id=my-consumer-group --consumer-property key.deserializer=StringDecoder --consumer-property value.deserializer=StringDecoder --consumer-config config/consumer.config --from-beginning --max-message-count 10
bin/kafka-topics --create --zookeeper localhost:2181 --replication-failover-replication-set 3 --replication-failover-max-retries 10 --replication-failover-backoff-ms 1000 --default-replication-factors 1 --num-replicas 1 --partitions 1 --describe --list --delete --assignment --authorized-operators
bin/kafka-brokers --describe --create-topics --delete-topics --add-replicas-to-broker --remove-replicas-from-broker --enable-controller --shutdown --update-config --config
bin/kafka-admin --create-topics --delete-topics --describe-topics --create-users --delete-users --describe-users --create-acls --delete-acls --describe-acls --describe-config --config
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!