Apache Kafka ialah perkhidmatan baris gilir mesej yang popular yang membantu anda membina aplikasi berkemampuan tinggi, kependaman rendah. Jika anda perlu menggunakan Kafka dalam aplikasi anda, anda perlu biasa dengan pelbagai arahan Kafka.
Artikel ini akan memberikan anda gambaran keseluruhan arahan Kafka untuk membantu anda meningkatkan kecekapan kerja anda dengan cepat.
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-consumer
: Perintah ini membolehkan anda membaca data daripada Kafka menggunakan API Java. 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🎜2 🎜
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🎜4. Gunakan kafka-broker untuk menguruskan broker di Kafka🎜
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🎜5 Gunakan kafka-admin untuk menguruskan kelompok dalam Kafka🎜
bin/kafka-brokers --describe --create-topics --delete-topics --add-replicas-to-broker --remove-replicas-from-broker --enable-controller --shutdown --update-config --config🎜Ringkasan🎜🎜Artikel ini memberi anda gambaran keseluruhan tentang arahan Kafka dengan cepat. kecekapan. Perintah ini membantu anda mengurus topik, broker, kelompok dan data dalam Kafka. 🎜🎜Jika anda ingin mengetahui lebih lanjut tentang Kafka, anda boleh merujuk kepada dokumentasi rasmi Kafka. 🎜
Atas ialah kandungan terperinci Manual Rujukan Pantas Perintah Biasa Kafka: Penting untuk Kerja Cekap. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!