Eine Schritt-für-Schritt-Anleitung zum Erlernen der Verwendung von Kafka-Versionsabfragen-javaLernprogramm-php.cn

Eine Schritt-für-Schritt-Anleitung zum Erlernen der Verwendung von Kafka-Versionsabfragen

王林

Freigeben： 2024-02-01 08:05:06

Original

897 Leute haben es durchsucht

Eine Schritt-für-Schritt-Anleitung zum Erlernen der Verwendung von Kafka-Versionsabfragen

1. Installieren Sie Kafka

Laden Sie Apache Kafka herunter und installieren Sie es auf Ihrem Server.
Extrahieren Sie Kafka-Archivdateien.
Setzen Sie die Umgebungsvariable KAFKA_HOME auf das Kafka-Installationsverzeichnis. KAFKA_HOME为Kafka安装目录。

2. 启动ZooKeeper

ZooKeeper是Kafka的依赖项，因此在启动Kafka之前必须先启动它。
打开命令行终端并导航到$KAFKA_HOME/bin目录。
运行以下命令启动ZooKeeper：

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

Nach dem Login kopieren

3. 启动Kafka服务器

打开命令行终端并导航到$KAFKA_HOME/bin目录。
运行以下命令启动Kafka服务器：

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

Nach dem Login kopieren

4. 创建主题

主题是Kafka中数据的逻辑分组。
要创建主题，请打开命令行终端并导航到$KAFKA_HOME/bin目录。
运行以下命令创建主题：

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

Nach dem Login kopieren

5. 发送消息

要向主题发送消息，请打开命令行终端并导航到$KAFKA_HOME/bin目录。
运行以下命令发送消息：

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

Nach dem Login kopieren

6. 消费消息

要消费主题的消息，请打开命令行终端并导航到$KAFKA_HOME/bin目录。
运行以下命令消费消息：

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

Nach dem Login kopieren

7. 查询版本

要查询Kafka服务器的版本，请打开命令行终端并导航到$KAFKA_HOME/bin

ZooKeeper ist eine Abhängigkeit von Kafka und muss daher vor dem Start von Kafka gestartet werden.

🎜Öffnen Sie ein Befehlszeilenterminal und navigieren Sie zum Verzeichnis $KAFKA_HOME/bin. 🎜🎜Führen Sie den folgenden Befehl aus, um ZooKeeper zu starten: 🎜🎜

./kafka-version.sh

Nach dem Login kopieren

🎜🎜3. Starten Sie den Kafka-Server. 🎜🎜🎜🎜Öffnen Sie ein Befehlszeilenterminal und navigieren Sie zum Verzeichnis $KAFKA_HOME/bin. 🎜🎜Starten Sie den Kafka-Server, indem Sie den folgenden Befehl ausführen: 🎜🎜

kafka-version.sh:
 version: 2.8.0
 kafka-version: 2.8.0
 kafka-storage: 2.8.0
 kafka-clients: 2.8.0
 kafka-streams: 2.8.0
 kafka-connect: 2.8.0
 kafka-admin: 2.8.0
 kafka-tools: 2.8.0

Nach dem Login kopieren

🎜🎜4. Erstellen Sie ein Thema 🎜🎜🎜🎜Ein Thema ist eine logische Gruppierung von Daten in Kafka. 🎜🎜Um ein Design zu erstellen, öffnen Sie ein Befehlszeilenterminal und navigieren Sie zum Verzeichnis $KAFKA_HOME/bin. 🎜🎜Führen Sie den folgenden Befehl aus, um ein Thema zu erstellen: 🎜🎜rrreee🎜🎜5. Senden Sie eine Nachricht 🎜🎜🎜🎜Um eine Nachricht an das Thema zu senden, öffnen Sie ein Befehlszeilenterminal und navigieren Sie zum

$KAFKA_HOME/bin Verzeichnis. 🎜🎜Führen Sie den folgenden Befehl aus, um eine Nachricht zu senden: 🎜🎜rrreee🎜🎜6. Nachrichten konsumieren 🎜🎜🎜🎜Um Nachrichten aus einem Thema zu konsumieren, öffnen Sie ein Befehlszeilenterminal und navigieren Sie zum <code>$KAFKA_HOME/bin

Verzeichnis. 🎜🎜Führen Sie den folgenden Befehl aus, um Nachrichten zu konsumieren: 🎜🎜rrreee🎜🎜7. Version abfragen 🎜🎜🎜🎜Um die Version des Kafka-Servers abzufragen, öffnen Sie ein Befehlszeilenterminal und navigieren Sie zu

$KAFKA_HOME/bin Code> Verzeichnis. 🎜🎜Führen Sie den folgenden Befehl aus, um die Version abzufragen: 🎜🎜rrreee🎜🎜Beispielausgabe🎜🎜rrreee

Das obige ist der detaillierte Inhalt vonEine Schritt-für-Schritt-Anleitung zum Erlernen der Verwendung von Kafka-Versionsabfragen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!