Apache Kafka ist ein beliebter Nachrichtenwarteschlangendienst, der Sie beim Erstellen von Anwendungen mit hohem Durchsatz und geringer Latenz unterstützt. Wenn Sie Kafka in Ihrer Anwendung verwenden müssen, müssen Sie mit den verschiedenen Befehlen von Kafka vertraut sein.
Dieser Artikel bietet Ihnen einen Überblick über Kafka-Befehle, die Ihnen helfen, Ihre Arbeitseffizienz schnell zu verbessern.
kafka-console-producer
: Mit diesem Befehl können Sie Daten über die Befehlszeile an Kafka senden. 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
: Mit diesem Befehl können Sie Daten mithilfe der Java-API an Kafka senden. kafka-console-consumer
: Mit diesem Befehl können Sie Daten in Kafka über die Befehlszeile lesen. kafka-consumer
: Mit diesem Befehl können Sie Daten aus Kafka mithilfe der Java-API lesen. kafka-topics
: Mit diesem Befehl können Sie Themen in Kafka verwalten. kafka-brokers
: Mit diesem Befehl können Sie Broker in Kafka verwalten.
kafka-admin
: Mit diesem Befehl können Sie Cluster in Kafka verwalten.
kafka-cat
: Mit diesem Befehl können Sie Nachrichten in Kafka anzeigen. 🎜🎜kafka-diff
: Mit diesem Befehl können Sie Cluster in Kafka unterscheiden. 🎜🎜kafka-mirror-topics
: Mit diesem Befehl können Sie Themen in Kafka in einen anderen Cluster spiegeln. 🎜🎜🎜5. Konfigurationsbefehl 🎜🎜🎜kafka-configs
: Mit diesem Befehl können Sie die Konfigurationsdateien des Clusters in Kafka verwalten. 🎜🎜🎜Spezifische Befehlsbeispiele🎜🎜1. Verwenden Sie kafka-console-producer, um Daten an Kafka zu senden 🎜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
Das obige ist der detaillierte Inhalt vonKafka Common Commands Kurzreferenzhandbuch: Unverzichtbar für effizientes Arbeiten. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!