Heim  >  Artikel  >  Java  >  Eine Schritt-für-Schritt-Anleitung zum Erlernen der Verwendung von Kafka-Versionsabfragen

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

王林
王林Original
2024-02-01 08:05:06918Durchsuche

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

3. 启动Kafka服务器

  • 打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令启动Kafka服务器:
./kafka-server-start.sh config/server.properties

4. 创建主题

  • 主题是Kafka中数据的逻辑分组。
  • 要创建主题,请打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令创建主题:
./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1

5. 发送消息

  • 要向主题发送消息,请打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令发送消息:
./kafka-console-producer.sh --topic my-topic --message "Hello, world!"

6. 消费消息

  • 要消费主题的消息,请打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令消费消息:
./kafka-console-consumer.sh --topic my-topic --from-beginning

7. 查询版本

  • 要查询Kafka服务器的版本,请打开命令行终端并导航到$KAFKA_HOME/bin
  • 2. ZooKeeper starten

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
🎜🎜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
🎜🎜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!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn