Testnachrichten aus einem Hermes -Thema mit dem Kafka-Client verbrauchen

Freigeben Version: Washingtondc

Aktualisiert 1. Februar 2024

2 Minuten Lesedauer

Verbrauchen Sie Testnachrichten aus einem Hermes -Thema, indem Sie zwei Verbraucher-Clients konfigurieren.

Vorbereitungen

Sichern Sie Ihre Kafka-Themen, indem Sie ein von der Instanz ServiceNow® signiertes Zertifikat und einen Schlüsselspeicher generieren. Sie müssen Truststore- und Schlüsselspeicher-Details angeben, wenn Sie die Hermes -Verbraucher konfigurieren. Weitere Informationen finden Sie unter Richten Sie eine sichere Verbindung zum ein Hermes Messaging-Service.
Sie müssen ein Thema erstellen und Testnachrichten im Kafka-Cluster Hermes erstellen, bevor Sie Nachrichten verarbeiten können. Details finden Sie unter Erstellen Sie mit dem Kafka-Client ein Testthema in Hermes . und Testnachrichten an ein Hermes -Thema mit dem Kafka-Client erstellen.

Erforderliche Rolle: admin

Warum und wann dieser Vorgang ausgeführt wird

In den folgenden Schritten wird beschrieben, wie zwei Verbraucher-Clients konfiguriert und Testnachrichten vom Hermes Kafka-Cluster empfangen werden. Da Hermes ein Paar Kafka-Cluster verwendet, sind zwei Verbraucher-Clients erforderlich. Dies bedeutet, dass zwei unterschiedliche Bootstrap-Adressen verwendet werden sollten, eine für jeden Verbraucher.

Befolgen Sie diese Schritte, wenn Sie bereit sind, Nachrichten von Hermes für Geschäfts- oder Produktionszwecke zu verwenden.

Prozedur

Laden Sie Apache Kafkaherunter, und installieren Sie sie.
1. Laden Sie die herunter Apache Kafka Binärdateien.
2. Entpacken Sie das Kafka-Paket, indem Sie den folgenden Befehl ausführen:
```
tar -zxvf kafka_2.13-3.1.2.tgz
```
Navigieren Sie zum Kafka-Verzeichnis, indem Sie den folgenden Befehl ausführen:
```
cd kafka_2.13-3.1.2
```
Konfigurieren Sie die Verbraucher.
1. Öffnen Sie die Datei config/consumer.properties.
2. Konfigurieren Sie die folgenden SSL-Eigenschaften:
```
security.protocol=SSL

ssl.truststore.password=<truststore password>

ssl.truststore.location=<path to truststore.p12>

ssl.truststore.type=PKCS12

ssl.keystore.password=<keystore password>

ssl.keystore.location=<path to keystore.p12>

ssl.keystore.type=PKCS12

ssl.key.password=<keystore password>
```
  Ersetzen Sie die folgenden Platzhaltervariablen:
  - <truststore password>mit Ihrem Truststore-Passwort
  - <path to truststore.p12>durch den Pfad zu Ihrer Truststore-Datei
  - <keystore password>mit Ihrem Schlüsselspeicher-Passwort
  - <path to keystore.p12>durch den Pfad zu Ihrer Schlüsselspeicherdatei

Verbrauchen Sie eine Nachricht mit jedem Verbraucher.

Führen Sie den folgenden Befehl für den ersten Verbraucher-Client aus:

Unix:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103

Windows:

./bin/windows/kafka-console-consumer.bat --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103

Ersetzen Sie die folgenden Platzhaltervariablen:

<instance_name>mit Ihrem Instanznamen
<namespace>mit dem Namespace der Domäne, zu der Ihr Kafka-Thema gehört (optional)
<app_id>mit der Anwendungs-ID
<topic_name>mit einem Testthemennamen
<consumer_group_id>mit einer Bezeichnung Ihrer Wahl für die Gruppe, der der Verbraucher angehört

Hinweis:

Bei jedem Teil des Themennamens wird zwischen Groß- und Kleinschreibung unterschieden.

Öffnen Sie ein neues Terminalfenster.

Führen Sie den folgenden Befehl für den zweiten Verbraucher-Client aus:

Unix:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203

Windows:

./bin/windows/kafka-console-consumer.bat --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203

Ersetzen Sie die folgenden Platzhaltervariablen:

<instance_name>mit Ihrem Instanznamen
<namespace>mit dem Namespace der Domäne, zu der Ihr Kafka-Thema gehört (optional)
<topic_name>mit einem Testthemennamen
<consumer_group_id>mit einer Bezeichnung Ihrer Wahl für die Gruppe, der der Verbraucher angehört

Hinweis:

Bei jedem Teil des Themennamens wird zwischen Groß- und Kleinschreibung unterschieden.

Ergebnisse

Testnachrichten werden aus dem Kafka-Cluster Hermes verwendet.